protocol.txt

This text file contains the kafka protocol messages that are not yet implemented.

          Produce API (Key: 0):

*Requests:*

Produce Request (Version: 0) => acks timeout [topic_data]
  acks => INT16
  timeout => INT32
  topic_data => topic [data]
    topic => STRING
    data => partition record_set
      partition => INT32
      record_set => RECORDS

Field 	Description
acks	The number of acknowledgments the producer requires the leader to
have received before considering a request complete. Allowed values: 0
for no acknowledgments, 1 for only the leader and -1 for the full ISR.
timeout	The time to await a response in ms.
topic_data	null
topic	Name of topic
data	null
partition	Topic partition id
record_set	null

Produce Request (Version: 1) => acks timeout [topic_data]
  acks => INT16
  timeout => INT32
  topic_data => topic [data]
    topic => STRING
    data => partition record_set
      partition => INT32
      record_set => RECORDS

Field 	Description
acks	The number of acknowledgments the producer requires the leader to
have received before considering a request complete. Allowed values: 0
for no acknowledgments, 1 for only the leader and -1 for the full ISR.
timeout	The time to await a response in ms.
topic_data	null
topic	Name of topic
data	null
partition	Topic partition id
record_set	null

Produce Request (Version: 2) => acks timeout [topic_data]
  acks => INT16
  timeout => INT32
  topic_data => topic [data]
    topic => STRING
    data => partition record_set
      partition => INT32
      record_set => RECORDS

Field 	Description
acks	The number of acknowledgments the producer requires the leader to
have received before considering a request complete. Allowed values: 0
for no acknowledgments, 1 for only the leader and -1 for the full ISR.
timeout	The time to await a response in ms.
topic_data	null
topic	Name of topic
data	null
partition	Topic partition id
record_set	null

Produce Request (Version: 3) => transactional_id acks timeout [topic_data]
  transactional_id => NULLABLE_STRING
  acks => INT16
  timeout => INT32
  topic_data => topic [data]
    topic => STRING
    data => partition record_set
      partition => INT32
      record_set => RECORDS

Field 	Description
transactional_id	The transactional id or null if the producer is not
transactional
acks	The number of acknowledgments the producer requires the leader to
have received before considering a request complete. Allowed values: 0
for no acknowledgments, 1 for only the leader and -1 for the full ISR.
timeout	The time to await a response in ms.
topic_data	null
topic	Name of topic
data	null
partition	Topic partition id
record_set	null

Produce Request (Version: 4) => transactional_id acks timeout [topic_data]
  transactional_id => NULLABLE_STRING
  acks => INT16
  timeout => INT32
  topic_data => topic [data]
    topic => STRING
    data => partition record_set
      partition => INT32
      record_set => RECORDS

Field 	Description
transactional_id	The transactional id or null if the producer is not
transactional
acks	The number of acknowledgments the producer requires the leader to
have received before considering a request complete. Allowed values: 0
for no acknowledgments, 1 for only the leader and -1 for the full ISR.
timeout	The time to await a response in ms.
topic_data	null
topic	Name of topic
data	null
partition	Topic partition id
record_set	null

Produce Request (Version: 5) => transactional_id acks timeout [topic_data]
  transactional_id => NULLABLE_STRING
  acks => INT16
  timeout => INT32
  topic_data => topic [data]
    topic => STRING
    data => partition record_set
      partition => INT32
      record_set => RECORDS

Field 	Description
transactional_id	The transactional id or null if the producer is not
transactional
acks	The number of acknowledgments the producer requires the leader to
have received before considering a request complete. Allowed values: 0
for no acknowledgments, 1 for only the leader and -1 for the full ISR.
timeout	The time to await a response in ms.
topic_data	null
topic	Name of topic
data	null
partition	Topic partition id
record_set	null

Produce Request (Version: 6) => transactional_id acks timeout [topic_data]
  transactional_id => NULLABLE_STRING
  acks => INT16
  timeout => INT32
  topic_data => topic [data]
    topic => STRING
    data => partition record_set
      partition => INT32
      record_set => RECORDS

Field 	Description
transactional_id	The transactional id or null if the producer is not
transactional
acks	The number of acknowledgments the producer requires the leader to
have received before considering a request complete. Allowed values: 0
for no acknowledgments, 1 for only the leader and -1 for the full ISR.
timeout	The time to await a response in ms.
topic_data	null
topic	Name of topic
data	null
partition	Topic partition id
record_set	null

Produce Request (Version: 7) => transactional_id acks timeout [topic_data]
  transactional_id => NULLABLE_STRING
  acks => INT16
  timeout => INT32
  topic_data => topic [data]
    topic => STRING
    data => partition record_set
      partition => INT32
      record_set => RECORDS

Field 	Description
transactional_id	The transactional id or null if the producer is not
transactional
acks	The number of acknowledgments the producer requires the leader to
have received before considering a request complete. Allowed values: 0
for no acknowledgments, 1 for only the leader and -1 for the full ISR.
timeout	The time to await a response in ms.
topic_data	null
topic	Name of topic
data	null
partition	Topic partition id
record_set	null

Produce Response (Version: 0) => [responses]
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition error_code base_offset
      partition => INT32
      error_code => INT16
      base_offset => INT64

Field 	Description
responses	null
topic	Name of topic
partition_responses	null
partition	Topic partition id
error_code	Response error code
base_offset	null

Produce Response (Version: 1) => [responses] throttle_time_ms
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition error_code base_offset
      partition => INT32
      error_code => INT16
      base_offset => INT64
  throttle_time_ms => INT32

Field 	Description
responses	null
topic	Name of topic
partition_responses	null
partition	Topic partition id
error_code	Response error code
base_offset	null
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

Produce Response (Version: 2) => [responses] throttle_time_ms
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition error_code base_offset log_append_time
      partition => INT32
      error_code => INT16
      base_offset => INT64
      log_append_time => INT64
  throttle_time_ms => INT32

Field 	Description
responses	null
topic	Name of topic
partition_responses	null
partition	Topic partition id
error_code	Response error code
base_offset	null
log_append_time	The timestamp returned by broker after appending the
messages. If CreateTime is used for the topic, the timestamp will be -1.
If LogAppendTime is used for the topic, the timestamp will be the broker
local time when the messages are appended.
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

Produce Response (Version: 3) => [responses] throttle_time_ms
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition error_code base_offset log_append_time
      partition => INT32
      error_code => INT16
      base_offset => INT64
      log_append_time => INT64
  throttle_time_ms => INT32

Field 	Description
responses	null
topic	Name of topic
partition_responses	null
partition	Topic partition id
error_code	Response error code
base_offset	null
log_append_time	The timestamp returned by broker after appending the
messages. If CreateTime is used for the topic, the timestamp will be -1.
If LogAppendTime is used for the topic, the timestamp will be the broker
local time when the messages are appended.
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

Produce Response (Version: 4) => [responses] throttle_time_ms
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition error_code base_offset log_append_time
      partition => INT32
      error_code => INT16
      base_offset => INT64
      log_append_time => INT64
  throttle_time_ms => INT32

Field 	Description
responses	null
topic	Name of topic
partition_responses	null
partition	Topic partition id
error_code	Response error code
base_offset	null
log_append_time	The timestamp returned by broker after appending the
messages. If CreateTime is used for the topic, the timestamp will be -1.
If LogAppendTime is used for the topic, the timestamp will be the broker
local time when the messages are appended.
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

Produce Response (Version: 5) => [responses] throttle_time_ms
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition error_code base_offset log_append_time log_start_offset
      partition => INT32
      error_code => INT16
      base_offset => INT64
      log_append_time => INT64
      log_start_offset => INT64
  throttle_time_ms => INT32

Field 	Description
responses	null
topic	Name of topic
partition_responses	null
partition	Topic partition id
error_code	Response error code
base_offset	null
log_append_time	The timestamp returned by broker after appending the
messages. If CreateTime is used for the topic, the timestamp will be -1.
If LogAppendTime is used for the topic, the timestamp will be the broker
local time when the messages are appended.
log_start_offset	The start offset of the log at the time this produce
response was created
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

Produce Response (Version: 6) => [responses] throttle_time_ms
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition error_code base_offset log_append_time log_start_offset
      partition => INT32
      error_code => INT16
      base_offset => INT64
      log_append_time => INT64
      log_start_offset => INT64
  throttle_time_ms => INT32

Field 	Description
responses	null
topic	Name of topic
partition_responses	null
partition	Topic partition id
error_code	Response error code
base_offset	null
log_append_time	The timestamp returned by broker after appending the
messages. If CreateTime is used for the topic, the timestamp will be -1.
If LogAppendTime is used for the topic, the timestamp will be the broker
local time when the messages are appended.
log_start_offset	The start offset of the log at the time this produce
response was created
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

Produce Response (Version: 7) => [responses] throttle_time_ms
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition error_code base_offset log_append_time log_start_offset
      partition => INT32
      error_code => INT16
      base_offset => INT64
      log_append_time => INT64
      log_start_offset => INT64
  throttle_time_ms => INT32

Field 	Description
responses	null
topic	Name of topic
partition_responses	null
partition	Topic partition id
error_code	Response error code
base_offset	null
log_append_time	The timestamp returned by broker after appending the
messages. If CreateTime is used for the topic, the timestamp will be -1.
If LogAppendTime is used for the topic, the timestamp will be the broker
local time when the messages are appended.
log_start_offset	The start offset of the log at the time this produce
response was created
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)


          Fetch API (Key: 1):

*Requests:*

Fetch Request (Version: 0) => replica_id max_wait_time min_bytes [topics]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  topics => topic [partitions]
    topic => STRING
    partitions => partition fetch_offset partition_max_bytes
      partition => INT32
      fetch_offset => INT64
      partition_max_bytes => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
fetch_offset	Message offset.
partition_max_bytes	Maximum bytes to fetch.

Fetch Request (Version: 1) => replica_id max_wait_time min_bytes [topics]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  topics => topic [partitions]
    topic => STRING
    partitions => partition fetch_offset partition_max_bytes
      partition => INT32
      fetch_offset => INT64
      partition_max_bytes => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
fetch_offset	Message offset.
partition_max_bytes	Maximum bytes to fetch.

Fetch Request (Version: 2) => replica_id max_wait_time min_bytes [topics]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  topics => topic [partitions]
    topic => STRING
    partitions => partition fetch_offset partition_max_bytes
      partition => INT32
      fetch_offset => INT64
      partition_max_bytes => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
fetch_offset	Message offset.
partition_max_bytes	Maximum bytes to fetch.

Fetch Request (Version: 3) => replica_id max_wait_time min_bytes max_bytes [topics]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  max_bytes => INT32
  topics => topic [partitions]
    topic => STRING
    partitions => partition fetch_offset partition_max_bytes
      partition => INT32
      fetch_offset => INT64
      partition_max_bytes => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
max_bytes	Maximum bytes to accumulate in the response. Note that this is
not an absolute maximum, if the first message in the first non-empty
partition of the fetch is larger than this value, the message will still
be returned to ensure that progress can be made.
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
fetch_offset	Message offset.
partition_max_bytes	Maximum bytes to fetch.

Fetch Request (Version: 4) => replica_id max_wait_time min_bytes max_bytes isolation_level [topics]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  max_bytes => INT32
  isolation_level => INT8
  topics => topic [partitions]
    topic => STRING
    partitions => partition fetch_offset partition_max_bytes
      partition => INT32
      fetch_offset => INT64
      partition_max_bytes => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
max_bytes	Maximum bytes to accumulate in the response. Note that this is
not an absolute maximum, if the first message in the first non-empty
partition of the fetch is larger than this value, the message will still
be returned to ensure that progress can be made.
isolation_level	This setting controls the visibility of transactional
records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records
visible. With READ_COMMITTED (isolation_level = 1), non-transactional
and COMMITTED transactional records are visible. To be more concrete,
READ_COMMITTED returns all data from offsets smaller than the current
LSO (last stable offset), and enables the inclusion of the list of
aborted transactions in the result, which allows consumers to discard
ABORTED transactional records
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
fetch_offset	Message offset.
partition_max_bytes	Maximum bytes to fetch.

Fetch Request (Version: 5) => replica_id max_wait_time min_bytes max_bytes isolation_level [topics]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  max_bytes => INT32
  isolation_level => INT8
  topics => topic [partitions]
    topic => STRING
    partitions => partition fetch_offset log_start_offset partition_max_bytes
      partition => INT32
      fetch_offset => INT64
      log_start_offset => INT64
      partition_max_bytes => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
max_bytes	Maximum bytes to accumulate in the response. Note that this is
not an absolute maximum, if the first message in the first non-empty
partition of the fetch is larger than this value, the message will still
be returned to ensure that progress can be made.
isolation_level	This setting controls the visibility of transactional
records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records
visible. With READ_COMMITTED (isolation_level = 1), non-transactional
and COMMITTED transactional records are visible. To be more concrete,
READ_COMMITTED returns all data from offsets smaller than the current
LSO (last stable offset), and enables the inclusion of the list of
aborted transactions in the result, which allows consumers to discard
ABORTED transactional records
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
fetch_offset	Message offset.
log_start_offset	Earliest available offset of the follower replica. The
field is only used when request is sent by follower.
partition_max_bytes	Maximum bytes to fetch.

Fetch Request (Version: 6) => replica_id max_wait_time min_bytes max_bytes isolation_level [topics]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  max_bytes => INT32
  isolation_level => INT8
  topics => topic [partitions]
    topic => STRING
    partitions => partition fetch_offset log_start_offset partition_max_bytes
      partition => INT32
      fetch_offset => INT64
      log_start_offset => INT64
      partition_max_bytes => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
max_bytes	Maximum bytes to accumulate in the response. Note that this is
not an absolute maximum, if the first message in the first non-empty
partition of the fetch is larger than this value, the message will still
be returned to ensure that progress can be made.
isolation_level	This setting controls the visibility of transactional
records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records
visible. With READ_COMMITTED (isolation_level = 1), non-transactional
and COMMITTED transactional records are visible. To be more concrete,
READ_COMMITTED returns all data from offsets smaller than the current
LSO (last stable offset), and enables the inclusion of the list of
aborted transactions in the result, which allows consumers to discard
ABORTED transactional records
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
fetch_offset	Message offset.
log_start_offset	Earliest available offset of the follower replica. The
field is only used when request is sent by follower.
partition_max_bytes	Maximum bytes to fetch.

Fetch Request (Version: 7) => replica_id max_wait_time min_bytes max_bytes isolation_level session_id session_epoch [topics] [forgotten_topics_data]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  max_bytes => INT32
  isolation_level => INT8
  session_id => INT32
  session_epoch => INT32
  topics => topic [partitions]
    topic => STRING
    partitions => partition fetch_offset log_start_offset partition_max_bytes
      partition => INT32
      fetch_offset => INT64
      log_start_offset => INT64
      partition_max_bytes => INT32
  forgotten_topics_data => topic [partitions]
    topic => STRING
    partitions => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
max_bytes	Maximum bytes to accumulate in the response. Note that this is
not an absolute maximum, if the first message in the first non-empty
partition of the fetch is larger than this value, the message will still
be returned to ensure that progress can be made.
isolation_level	This setting controls the visibility of transactional
records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records
visible. With READ_COMMITTED (isolation_level = 1), non-transactional
and COMMITTED transactional records are visible. To be more concrete,
READ_COMMITTED returns all data from offsets smaller than the current
LSO (last stable offset), and enables the inclusion of the list of
aborted transactions in the result, which allows consumers to discard
ABORTED transactional records
session_id	The fetch session ID
session_epoch	The fetch session epoch
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
fetch_offset	Message offset.
log_start_offset	Earliest available offset of the follower replica. The
field is only used when request is sent by follower.
partition_max_bytes	Maximum bytes to fetch.
forgotten_topics_data	Topics to remove from the fetch session.
topic	Name of topic
partitions	Partitions to remove from the fetch session.

Fetch Request (Version: 8) => replica_id max_wait_time min_bytes max_bytes isolation_level session_id session_epoch [topics] [forgotten_topics_data]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  max_bytes => INT32
  isolation_level => INT8
  session_id => INT32
  session_epoch => INT32
  topics => topic [partitions]
    topic => STRING
    partitions => partition fetch_offset log_start_offset partition_max_bytes
      partition => INT32
      fetch_offset => INT64
      log_start_offset => INT64
      partition_max_bytes => INT32
  forgotten_topics_data => topic [partitions]
    topic => STRING
    partitions => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
max_bytes	Maximum bytes to accumulate in the response. Note that this is
not an absolute maximum, if the first message in the first non-empty
partition of the fetch is larger than this value, the message will still
be returned to ensure that progress can be made.
isolation_level	This setting controls the visibility of transactional
records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records
visible. With READ_COMMITTED (isolation_level = 1), non-transactional
and COMMITTED transactional records are visible. To be more concrete,
READ_COMMITTED returns all data from offsets smaller than the current
LSO (last stable offset), and enables the inclusion of the list of
aborted transactions in the result, which allows consumers to discard
ABORTED transactional records
session_id	The fetch session ID
session_epoch	The fetch session epoch
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
fetch_offset	Message offset.
log_start_offset	Earliest available offset of the follower replica. The
field is only used when request is sent by follower.
partition_max_bytes	Maximum bytes to fetch.
forgotten_topics_data	Topics to remove from the fetch session.
topic	Name of topic
partitions	Partitions to remove from the fetch session.

Fetch Request (Version: 9) => replica_id max_wait_time min_bytes max_bytes isolation_level session_id session_epoch [topics] [forgotten_topics_data]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  max_bytes => INT32
  isolation_level => INT8
  session_id => INT32
  session_epoch => INT32
  topics => topic [partitions]
    topic => STRING
    partitions => partition current_leader_epoch fetch_offset log_start_offset partition_max_bytes
      partition => INT32
      current_leader_epoch => INT32
      fetch_offset => INT64
      log_start_offset => INT64
      partition_max_bytes => INT32
  forgotten_topics_data => topic [partitions]
    topic => STRING
    partitions => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
max_bytes	Maximum bytes to accumulate in the response. Note that this is
not an absolute maximum, if the first message in the first non-empty
partition of the fetch is larger than this value, the message will still
be returned to ensure that progress can be made.
isolation_level	This setting controls the visibility of transactional
records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records
visible. With READ_COMMITTED (isolation_level = 1), non-transactional
and COMMITTED transactional records are visible. To be more concrete,
READ_COMMITTED returns all data from offsets smaller than the current
LSO (last stable offset), and enables the inclusion of the list of
aborted transactions in the result, which allows consumers to discard
ABORTED transactional records
session_id	The fetch session ID
session_epoch	The fetch session epoch
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
current_leader_epoch	The current leader epoch, if provided, is used to
fence consumers/replicas with old metadata. If the epoch provided by the
client is larger than the current epoch known to the broker, then the
UNKNOWN_LEADER_EPOCH error code will be returned. If the provided epoch
is smaller, then the FENCED_LEADER_EPOCH error code will be returned.
fetch_offset	Message offset.
log_start_offset	Earliest available offset of the follower replica. The
field is only used when request is sent by follower.
partition_max_bytes	Maximum bytes to fetch.
forgotten_topics_data	Topics to remove from the fetch session.
topic	Name of topic
partitions	Partitions to remove from the fetch session.

Fetch Request (Version: 10) => replica_id max_wait_time min_bytes max_bytes isolation_level session_id session_epoch [topics] [forgotten_topics_data]
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  max_bytes => INT32
  isolation_level => INT8
  session_id => INT32
  session_epoch => INT32
  topics => topic [partitions]
    topic => STRING
    partitions => partition current_leader_epoch fetch_offset log_start_offset partition_max_bytes
      partition => INT32
      current_leader_epoch => INT32
      fetch_offset => INT64
      log_start_offset => INT64
      partition_max_bytes => INT32
  forgotten_topics_data => topic [partitions]
    topic => STRING
    partitions => INT32

Field 	Description
replica_id	Broker id of the follower. For normal consumers, use -1.
max_wait_time	Maximum time in ms to wait for the response.
min_bytes	Minimum bytes to accumulate in the response.
max_bytes	Maximum bytes to accumulate in the response. Note that this is
not an absolute maximum, if the first message in the first non-empty
partition of the fetch is larger than this value, the message will still
be returned to ensure that progress can be made.
isolation_level	This setting controls the visibility of transactional
records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records
visible. With READ_COMMITTED (isolation_level = 1), non-transactional
and COMMITTED transactional records are visible. To be more concrete,
READ_COMMITTED returns all data from offsets smaller than the current
LSO (last stable offset), and enables the inclusion of the list of
aborted transactions in the result, which allows consumers to discard
ABORTED transactional records
session_id	The fetch session ID
session_epoch	The fetch session epoch
topics	Topics to fetch in the order provided.
topic	Name of topic
partitions	Partitions to fetch.
partition	Topic partition id
current_leader_epoch	The current leader epoch, if provided, is used to
fence consumers/replicas with old metadata. If the epoch provided by the
client is larger than the current epoch known to the broker, then the
UNKNOWN_LEADER_EPOCH error code will be returned. If the provided epoch
is smaller, then the FENCED_LEADER_EPOCH error code will be returned.
fetch_offset	Message offset.
log_start_offset	Earliest available offset of the follower replica. The
field is only used when request is sent by follower.
partition_max_bytes	Maximum bytes to fetch.
forgotten_topics_data	Topics to remove from the fetch session.
topic	Name of topic
partitions	Partitions to remove from the fetch session.

Fetch Response (Version: 0) => [responses]
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark
        partition => INT32
        error_code => INT16
        high_watermark => INT64
      record_set => RECORDS

Field 	Description
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
record_set	null

Fetch Response (Version: 1) => throttle_time_ms [responses]
  throttle_time_ms => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark
        partition => INT32
        error_code => INT16
        high_watermark => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
record_set	null

Fetch Response (Version: 2) => throttle_time_ms [responses]
  throttle_time_ms => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark
        partition => INT32
        error_code => INT16
        high_watermark => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
record_set	null

Fetch Response (Version: 3) => throttle_time_ms [responses]
  throttle_time_ms => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark
        partition => INT32
        error_code => INT16
        high_watermark => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
record_set	null

Fetch Response (Version: 4) => throttle_time_ms [responses]
  throttle_time_ms => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark last_stable_offset [aborted_transactions]
        partition => INT32
        error_code => INT16
        high_watermark => INT64
        last_stable_offset => INT64
        aborted_transactions => producer_id first_offset
          producer_id => INT64
          first_offset => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
last_stable_offset	The last stable offset (or LSO) of the partition.
This is the last offset such that the state of all transactional records
prior to this offset have been decided (ABORTED or COMMITTED)
aborted_transactions	null
producer_id	The producer id associated with the aborted transactions
first_offset	The first offset in the aborted transaction
record_set	null

Fetch Response (Version: 5) => throttle_time_ms [responses]
  throttle_time_ms => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark last_stable_offset log_start_offset [aborted_transactions]
        partition => INT32
        error_code => INT16
        high_watermark => INT64
        last_stable_offset => INT64
        log_start_offset => INT64
        aborted_transactions => producer_id first_offset
          producer_id => INT64
          first_offset => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
last_stable_offset	The last stable offset (or LSO) of the partition.
This is the last offset such that the state of all transactional records
prior to this offset have been decided (ABORTED or COMMITTED)
log_start_offset	Earliest available offset.
aborted_transactions	null
producer_id	The producer id associated with the aborted transactions
first_offset	The first offset in the aborted transaction
record_set	null

Fetch Response (Version: 6) => throttle_time_ms [responses]
  throttle_time_ms => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark last_stable_offset log_start_offset [aborted_transactions]
        partition => INT32
        error_code => INT16
        high_watermark => INT64
        last_stable_offset => INT64
        log_start_offset => INT64
        aborted_transactions => producer_id first_offset
          producer_id => INT64
          first_offset => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
last_stable_offset	The last stable offset (or LSO) of the partition.
This is the last offset such that the state of all transactional records
prior to this offset have been decided (ABORTED or COMMITTED)
log_start_offset	Earliest available offset.
aborted_transactions	null
producer_id	The producer id associated with the aborted transactions
first_offset	The first offset in the aborted transaction
record_set	null

Fetch Response (Version: 7) => throttle_time_ms error_code session_id [responses]
  throttle_time_ms => INT32
  error_code => INT16
  session_id => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark last_stable_offset log_start_offset [aborted_transactions]
        partition => INT32
        error_code => INT16
        high_watermark => INT64
        last_stable_offset => INT64
        log_start_offset => INT64
        aborted_transactions => producer_id first_offset
          producer_id => INT64
          first_offset => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	Response error code
session_id	The fetch session ID
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
last_stable_offset	The last stable offset (or LSO) of the partition.
This is the last offset such that the state of all transactional records
prior to this offset have been decided (ABORTED or COMMITTED)
log_start_offset	Earliest available offset.
aborted_transactions	null
producer_id	The producer id associated with the aborted transactions
first_offset	The first offset in the aborted transaction
record_set	null

Fetch Response (Version: 8) => throttle_time_ms error_code session_id [responses]
  throttle_time_ms => INT32
  error_code => INT16
  session_id => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark last_stable_offset log_start_offset [aborted_transactions]
        partition => INT32
        error_code => INT16
        high_watermark => INT64
        last_stable_offset => INT64
        log_start_offset => INT64
        aborted_transactions => producer_id first_offset
          producer_id => INT64
          first_offset => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	Response error code
session_id	The fetch session ID
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
last_stable_offset	The last stable offset (or LSO) of the partition.
This is the last offset such that the state of all transactional records
prior to this offset have been decided (ABORTED or COMMITTED)
log_start_offset	Earliest available offset.
aborted_transactions	null
producer_id	The producer id associated with the aborted transactions
first_offset	The first offset in the aborted transaction
record_set	null

Fetch Response (Version: 9) => throttle_time_ms error_code session_id [responses]
  throttle_time_ms => INT32
  error_code => INT16
  session_id => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark last_stable_offset log_start_offset [aborted_transactions]
        partition => INT32
        error_code => INT16
        high_watermark => INT64
        last_stable_offset => INT64
        log_start_offset => INT64
        aborted_transactions => producer_id first_offset
          producer_id => INT64
          first_offset => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	Response error code
session_id	The fetch session ID
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
last_stable_offset	The last stable offset (or LSO) of the partition.
This is the last offset such that the state of all transactional records
prior to this offset have been decided (ABORTED or COMMITTED)
log_start_offset	Earliest available offset.
aborted_transactions	null
producer_id	The producer id associated with the aborted transactions
first_offset	The first offset in the aborted transaction
record_set	null

Fetch Response (Version: 10) => throttle_time_ms error_code session_id [responses]
  throttle_time_ms => INT32
  error_code => INT16
  session_id => INT32
  responses => topic [partition_responses]
    topic => STRING
    partition_responses => partition_header record_set
      partition_header => partition error_code high_watermark last_stable_offset log_start_offset [aborted_transactions]
        partition => INT32
        error_code => INT16
        high_watermark => INT64
        last_stable_offset => INT64
        log_start_offset => INT64
        aborted_transactions => producer_id first_offset
          producer_id => INT64
          first_offset => INT64
      record_set => RECORDS

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	Response error code
session_id	The fetch session ID
responses	null
topic	Name of topic
partition_responses	null
partition_header	null
partition	Topic partition id
error_code	Response error code
high_watermark	Last committed offset.
last_stable_offset	The last stable offset (or LSO) of the partition.
This is the last offset such that the state of all transactional records
prior to this offset have been decided (ABORTED or COMMITTED)
log_start_offset	Earliest available offset.
aborted_transactions	null
producer_id	The producer id associated with the aborted transactions
first_offset	The first offset in the aborted transaction
record_set	null

          DescribeLogDirs API (Key: 35):

*Requests:*

DescribeLogDirs Request (Version: 0) => [topics]
  topics => topic [partitions]
    topic => STRING
    partitions => INT32

Field 	Description
topics	null
topic	Name of topic
partitions	List of partition ids of the topic.

DescribeLogDirs Request (Version: 1) => [topics]
  topics => topic [partitions]
    topic => STRING
    partitions => INT32

Field 	Description
topics	null
topic	Name of topic
partitions	List of partition ids of the topic.

DescribeLogDirs Response (Version: 0) => throttle_time_ms [log_dirs]
  throttle_time_ms => INT32
  log_dirs => error_code log_dir [topics]
    error_code => INT16
    log_dir => STRING
    topics => topic [partitions]
      topic => STRING
      partitions => partition size offset_lag is_future
        partition => INT32
        size => INT64
        offset_lag => INT64
        is_future => BOOLEAN

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
log_dirs	null
error_code	Response error code
log_dir	The absolute log directory path.
topics	null
topic	Name of topic
partitions	null
partition	Topic partition id
size	The size of the log segments of the partition in bytes.
offset_lag	The lag of the log's LEO w.r.t. partition's HW (if it is the
current log for the partition) or current replica's LEO (if it is the
future log for the partition)
is_future	True if this log is created by AlterReplicaLogDirsRequest and
will replace the current log of the replica in the future.

DescribeLogDirs Response (Version: 1) => throttle_time_ms [log_dirs]
  throttle_time_ms => INT32
  log_dirs => error_code log_dir [topics]
    error_code => INT16
    log_dir => STRING
    topics => topic [partitions]
      topic => STRING
      partitions => partition size offset_lag is_future
        partition => INT32
        size => INT64
        offset_lag => INT64
        is_future => BOOLEAN

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
log_dirs	null
error_code	Response error code
log_dir	The absolute log directory path.
topics	null
topic	Name of topic
partitions	null
partition	Topic partition id
size	The size of the log segments of the partition in bytes.
offset_lag	The lag of the log's LEO w.r.t. partition's HW (if it is the
current log for the partition) or current replica's LEO (if it is the
future log for the partition)
is_future	True if this log is created by AlterReplicaLogDirsRequest and
will replace the current log of the replica in the future.


          SaslAuthenticate API (Key: 36):

*Requests:*

SaslAuthenticate Request (Version: 0) => sasl_auth_bytes
  sasl_auth_bytes => BYTES

Field 	Description
sasl_auth_bytes	SASL authentication bytes from client as defined by the
SASL mechanism.

SaslAuthenticate Response (Version: 0) => error_code error_message sasl_auth_bytes
  error_code => INT16
  error_message => NULLABLE_STRING
  sasl_auth_bytes => BYTES

Field 	Description
error_code	Response error code
error_message	Response error message
sasl_auth_bytes	SASL authentication bytes from server as defined by the
SASL mechanism.


          CreatePartitions API (Key: 37):

*Requests:*

CreatePartitions Request (Version: 0) => [topic_partitions] timeout validate_only
  topic_partitions => topic new_partitions
    topic => STRING
    new_partitions => count [assignment]
      count => INT32
      assignment => ARRAY(INT32)
  timeout => INT32
  validate_only => BOOLEAN

Field 	Description
topic_partitions	List of topic and the corresponding new partitions.
topic	Name of topic
new_partitions	null
count	The new partition count.
assignment	The assigned brokers.
timeout	The time in ms to wait for the partitions to be created.
validate_only	If true then validate the request, but don't actually
increase the number of partitions.

CreatePartitions Request (Version: 1) => [topic_partitions] timeout validate_only
  topic_partitions => topic new_partitions
    topic => STRING
    new_partitions => count [assignment]
      count => INT32
      assignment => ARRAY(INT32)
  timeout => INT32
  validate_only => BOOLEAN

Field 	Description
topic_partitions	List of topic and the corresponding new partitions.
topic	Name of topic
new_partitions	null
count	The new partition count.
assignment	The assigned brokers.
timeout	The time in ms to wait for the partitions to be created.
validate_only	If true then validate the request, but don't actually
increase the number of partitions.

CreatePartitions Response (Version: 0) => throttle_time_ms [topic_errors]
  throttle_time_ms => INT32
  topic_errors => topic error_code error_message
    topic => STRING
    error_code => INT16
    error_message => NULLABLE_STRING

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
topic_errors	Per topic results for the create partitions request
topic	Name of topic
error_code	Response error code
error_message	Response error message

CreatePartitions Response (Version: 1) => throttle_time_ms [topic_errors]
  throttle_time_ms => INT32
  topic_errors => topic error_code error_message
    topic => STRING
    error_code => INT16
    error_message => NULLABLE_STRING

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
topic_errors	Per topic results for the create partitions request
topic	Name of topic
error_code	Response error code
error_message	Response error message


          CreateDelegationToken API (Key: 38):

*Requests:*

CreateDelegationToken Request (Version: 0) => [renewers] max_life_time
  renewers => principal_type name
    principal_type => STRING
    name => STRING
  max_life_time => INT64

Field 	Description
renewers	An array of token renewers. Renewer is an Kafka PrincipalType
and name string, who is allowed to renew this token before the max
lifetime expires.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal
max_life_time	Max lifetime period for token in milli seconds. if value
is -1, then max lifetime will default to a server side config value.

CreateDelegationToken Request (Version: 1) => [renewers] max_life_time
  renewers => principal_type name
    principal_type => STRING
    name => STRING
  max_life_time => INT64

Field 	Description
renewers	An array of token renewers. Renewer is an Kafka PrincipalType
and name string, who is allowed to renew this token before the max
lifetime expires.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal
max_life_time	Max lifetime period for token in milli seconds. if value
is -1, then max lifetime will default to a server side config value.

CreateDelegationToken Response (Version: 0) => error_code owner issue_timestamp expiry_timestamp max_timestamp token_id hmac throttle_time_ms
  error_code => INT16
  owner => principal_type name
    principal_type => STRING
    name => STRING
  issue_timestamp => INT64
  expiry_timestamp => INT64
  max_timestamp => INT64
  token_id => STRING
  hmac => BYTES
  throttle_time_ms => INT32

Field 	Description
error_code	Response error code
owner	token owner.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal
issue_timestamp	timestamp (in msec) when this token was generated.
expiry_timestamp	timestamp (in msec) at which this token expires.
max_timestamp	max life time of this token.
token_id	UUID to ensure uniqueness.
hmac	HMAC of the delegation token.
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

CreateDelegationToken Response (Version: 1) => error_code owner issue_timestamp expiry_timestamp max_timestamp token_id hmac throttle_time_ms
  error_code => INT16
  owner => principal_type name
    principal_type => STRING
    name => STRING
  issue_timestamp => INT64
  expiry_timestamp => INT64
  max_timestamp => INT64
  token_id => STRING
  hmac => BYTES
  throttle_time_ms => INT32

Field 	Description
error_code	Response error code
owner	token owner.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal
issue_timestamp	timestamp (in msec) when this token was generated.
expiry_timestamp	timestamp (in msec) at which this token expires.
max_timestamp	max life time of this token.
token_id	UUID to ensure uniqueness.
hmac	HMAC of the delegation token.
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)


          RenewDelegationToken API (Key: 39):

*Requests:*

RenewDelegationToken Request (Version: 0) => hmac renew_time_period
  hmac => BYTES
  renew_time_period => INT64

Field 	Description
hmac	HMAC of the delegation token to be renewed.
renew_time_period	Renew time period in milli seconds.

RenewDelegationToken Request (Version: 1) => hmac renew_time_period
  hmac => BYTES
  renew_time_period => INT64

Field 	Description
hmac	HMAC of the delegation token to be renewed.
renew_time_period	Renew time period in milli seconds.

RenewDelegationToken Response (Version: 0) => error_code expiry_timestamp throttle_time_ms
  error_code => INT16
  expiry_timestamp => INT64
  throttle_time_ms => INT32

Field 	Description
error_code	Response error code
expiry_timestamp	timestamp (in msec) at which this token expires..
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

RenewDelegationToken Response (Version: 1) => error_code expiry_timestamp throttle_time_ms
  error_code => INT16
  expiry_timestamp => INT64
  throttle_time_ms => INT32

Field 	Description
error_code	Response error code
expiry_timestamp	timestamp (in msec) at which this token expires..
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)


          ExpireDelegationToken API (Key: 40):

*Requests:*

ExpireDelegationToken Request (Version: 0) => hmac expiry_time_period
  hmac => BYTES
  expiry_time_period => INT64

Field 	Description
hmac	HMAC of the delegation token to be expired.
expiry_time_period	expiry time period in milli seconds.

ExpireDelegationToken Request (Version: 1) => hmac expiry_time_period
  hmac => BYTES
  expiry_time_period => INT64

Field 	Description
hmac	HMAC of the delegation token to be expired.
expiry_time_period	expiry time period in milli seconds.

ExpireDelegationToken Response (Version: 0) => error_code expiry_timestamp throttle_time_ms
  error_code => INT16
  expiry_timestamp => INT64
  throttle_time_ms => INT32

Field 	Description
error_code	Response error code
expiry_timestamp	timestamp (in msec) at which this token expires..
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

ExpireDelegationToken Response (Version: 1) => error_code expiry_timestamp throttle_time_ms
  error_code => INT16
  expiry_timestamp => INT64
  throttle_time_ms => INT32

Field 	Description
error_code	Response error code
expiry_timestamp	timestamp (in msec) at which this token expires..
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)


          DescribeDelegationToken API (Key: 41):

*Requests:*

DescribeDelegationToken Request (Version: 0) => [owners]
  owners => principal_type name
    principal_type => STRING
    name => STRING

Field 	Description
owners	An array of token owners.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal

DescribeDelegationToken Request (Version: 1) => [owners]
  owners => principal_type name
    principal_type => STRING
    name => STRING

Field 	Description
owners	An array of token owners.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal

DescribeDelegationToken Response (Version: 0) => error_code [token_details] throttle_time_ms
  error_code => INT16
  token_details => owner issue_timestamp expiry_timestamp max_timestamp token_id hmac [renewers]
    owner => principal_type name
      principal_type => STRING
      name => STRING
    issue_timestamp => INT64
    expiry_timestamp => INT64
    max_timestamp => INT64
    token_id => STRING
    hmac => BYTES
    renewers => principal_type name
      principal_type => STRING
      name => STRING
  throttle_time_ms => INT32

Field 	Description
error_code	Response error code
token_details	null
owner	token owner.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal
issue_timestamp	timestamp (in msec) when this token was generated.
expiry_timestamp	timestamp (in msec) at which this token expires.
max_timestamp	max life time of this token.
token_id	UUID to ensure uniqueness.
hmac	HMAC of the delegation token to be expired.
renewers	An array of token renewers. Renewer is an Kafka PrincipalType
and name string, who is allowed to renew this token before the max
lifetime expires.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

DescribeDelegationToken Response (Version: 1) => error_code [token_details] throttle_time_ms
  error_code => INT16
  token_details => owner issue_timestamp expiry_timestamp max_timestamp token_id hmac [renewers]
    owner => principal_type name
      principal_type => STRING
      name => STRING
    issue_timestamp => INT64
    expiry_timestamp => INT64
    max_timestamp => INT64
    token_id => STRING
    hmac => BYTES
    renewers => principal_type name
      principal_type => STRING
      name => STRING
  throttle_time_ms => INT32

Field 	Description
error_code	Response error code
token_details	null
owner	token owner.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal
issue_timestamp	timestamp (in msec) when this token was generated.
expiry_timestamp	timestamp (in msec) at which this token expires.
max_timestamp	max life time of this token.
token_id	UUID to ensure uniqueness.
hmac	HMAC of the delegation token to be expired.
renewers	An array of token renewers. Renewer is an Kafka PrincipalType
and name string, who is allowed to renew this token before the max
lifetime expires.
principal_type	principalType of the Kafka principal
name	name of the Kafka principal
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)


          DeleteGroups API (Key: 42):

*Requests:*

DeleteGroups Request (Version: 0) => [groups]
  groups => STRING

Field 	Description
groups	An array of groups to be deleted.

DeleteGroups Request (Version: 1) => [groups]
  groups => STRING

Field 	Description
groups	An array of groups to be deleted.

DeleteGroups Response (Version: 0) => throttle_time_ms [group_error_codes]
  throttle_time_ms => INT32
  group_error_codes => group_id error_code
    group_id => STRING
    error_code => INT16

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
group_error_codes	An array of per group error codes.
group_id	The unique group identifier
error_code	Response error code

DeleteGroups Response (Version: 1) => throttle_time_ms [group_error_codes]
  throttle_time_ms => INT32
  group_error_codes => group_id error_code
    group_id => STRING
    error_code => INT16

Field 	Description
throttle_time_ms	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
group_error_codes	An array of per group error codes.
group_id	The unique group identifier
error_code	Response error code


        Some Common Philosophical Questions <#protocol_philosophy>

Some people have asked why we don't use HTTP. There are a number of
reasons, the best is that client implementors can make use of some of
the more advanced TCP features--the ability to multiplex requests, the
ability to simultaneously poll many connections, etc. We have also found
HTTP libraries in many languages to be surprisingly shabby.

Others have asked if maybe we shouldn't support many different
protocols. Prior experience with this was that it makes it very hard to
add and test new features if they have to be ported across many protocol
implementations. Our feeling is that most users don't really see
multiple protocols as a feature, they just want a good reliable client
in the language of their choice.

Another question is why we don't adopt XMPP, STOMP, AMQP or an existing
protocol. The answer to this varies by protocol, but in general the
problem is that the protocol does determine large parts of the
implementation and we couldn't do what we are doing if we didn't have
control over the protocol. Our belief is that it is possible to do
better than existing messaging systems have in providing a truly
distributed messaging system, and to do this we need to build something
that works differently.

A final question is why we don't use a system like Protocol Buffers or
Thrift to define our request messages. These packages excel at helping
you to managing lots and lots of serialized messages. However we have
only a few messages. Support across languages is somewhat spotty
(depending on the package). Finally the mapping between binary log
format and wire protocol is something we manage somewhat carefully and
this would not be possible with these systems. Finally we prefer the
style of versioning APIs explicitly and checking this to inferring new
values as nulls as it allows more nuanced control of compatibility.

The contents of this website are © 2017 Apache Software Foundation
<https://www.apache.org/> under the terms of the Apache License v2
<https://www.apache.org/licenses/LICENSE-2.0.html>. Apache Kafka, Kafka,
and the Kafka logo are either registered trademarks or trademarks of The
Apache Software Foundation in the United States and other countries.
Apache Feather <http://www.apache.org/>