kafka-clients 1.0 内部响应接口文档

AddOffsetsToTxnResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code

AddPartitionsToTxnResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
errors	ARRAY({topic:STRING,partition_errors:ARRAY({partition:INT32,error_code:INT16})})	null	null

AlterConfigsResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
resources	ARRAY({error_code:INT16,error_message:NULLABLE_STRING,resource_type:INT8,resource_name:STRING})	null	null

AlterReplicaLogDirsResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
topics	ARRAY({topic:STRING,partitions:ARRAY({partition:INT32,error_code:INT16})})	null	null

ApiVersionsResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
api_versions	ARRAY({api_key:INT16,min_version:INT16,max_version:INT16})	null	API versions supported by the broker.

version:1

name	type	defaultValue	docString
error_code	INT16	null	Response error code
api_versions	ARRAY({api_key:INT16,min_version:INT16,max_version:INT16})	null	API versions supported by the broker.
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

ControlledShutdownResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
partitions_remaining	ARRAY({topic:STRING,partition:INT32})	null	The partitions that the broker still leads.

version:1

name	type	defaultValue	docString
error_code	INT16	null	Response error code
partitions_remaining	ARRAY({topic:STRING,partition:INT32})	null	The partitions that the broker still leads.

CreateAclsResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
creation_responses	ARRAY({error_code:INT16,error_message:NULLABLE_STRING})	null	null

CreatePartitionsResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
topic_errors	ARRAY({topic:STRING,error_code:INT16,error_message:NULLABLE_STRING})	null	Per topic results for the create partitions request

CreateTopicsResponse

version:0

name	type	defaultValue	docString
topic_errors	ARRAY({topic:STRING,error_code:INT16})	null	An array of per topic error codes.

version:1

name	type	defaultValue	docString
topic_errors	ARRAY({topic:STRING,error_code:INT16,error_message:NULLABLE_STRING})	null	An array of per topic errors.

version:2

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
topic_errors	ARRAY({topic:STRING,error_code:INT16,error_message:NULLABLE_STRING})	null	An array of per topic errors.

DeleteAclsResponse

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
filter_responses	ARRAY({error_code:INT16,error_message:NULLABLE_STRING,matching_acls:ARRAY({error_code:INT16,error_message:NULLABLE_STRING,resource_type:INT8,resource_name:STRING,principal:STRING,host:STRING,operation:INT8,permission_type:INT8})})	null	null

DeleteRecordsResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
topics	ARRAY({topic:STRING,partitions:ARRAY({partition:INT32,low_watermark:INT64,error_code:INT16})})	null	null

DeleteTopicsResponse

version:0

name	type	defaultValue	docString
topic_error_codes	ARRAY({topic:STRING,error_code:INT16})	null	An array of per topic error codes.

version:1

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
topic_error_codes	ARRAY({topic:STRING,error_code:INT16})	null	An array of per topic error codes.

DescribeAclsResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code
error_message	NULLABLE_STRING	null	Response error message
resources	ARRAY({resource_type:INT8,resource_name:STRING,acls:ARRAY({principal:STRING,host:STRING,operation:INT8,permission_type:INT8})})	null	The resources and their associated ACLs.

DescribeConfigsResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
resources	ARRAY({error_code:INT16,error_message:NULLABLE_STRING,resource_type:INT8,resource_name:STRING,config_entries:ARRAY({config_name:STRING,config_value:NULLABLE_STRING,read_only:BOOLEAN,is_default:BOOLEAN,is_sensitive:BOOLEAN})})	null	null

DescribeGroupsResponse

version:0

name	type	defaultValue	docString
groups	ARRAY({error_code:INT16,group_id:STRING,state:STRING,protocol_type:STRING,protocol:STRING,members:ARRAY({member_id:STRING,client_id:STRING,client_host:STRING,member_metadata:BYTES,member_assignment:BYTES})})	null	null

version:1

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
groups	ARRAY({error_code:INT16,group_id:STRING,state:STRING,protocol_type:STRING,protocol:STRING,members:ARRAY({member_id:STRING,client_id:STRING,client_host:STRING,member_metadata:BYTES,member_assignment:BYTES})})	null	null

DescribeLogDirsResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
log_dirs	ARRAY({error_code:INT16,log_dir:STRING,topics:ARRAY({topic:STRING,partitions:ARRAY({partition:INT32,size:INT64,offset_lag:INT64,is_future:BOOLEAN})})})	null	null

EndTxnResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code

FetchResponse

version:0

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition_header:{partition:INT32,error_code:INT16,high_watermark:INT64},record_set:RECORDS})})	null	null

version:1

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition_header:{partition:INT32,error_code:INT16,high_watermark:INT64},record_set:RECORDS})})	null	null

version:2

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition_header:{partition:INT32,error_code:INT16,high_watermark:INT64},record_set:RECORDS})})	null	null

version:3

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition_header:{partition:INT32,error_code:INT16,high_watermark:INT64},record_set:RECORDS})})	null	null

version:4

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition_header:{partition:INT32,error_code:INT16,high_watermark:INT64,last_stable_offset:INT64,aborted_transactions:ARRAY({producer_id:INT64,first_offset:INT64})},record_set:RECORDS})})	null	null

version:5

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition_header:{partition:INT32,error_code:INT16,high_watermark:INT64,last_stable_offset:INT64,log_start_offset:INT64,aborted_transactions:ARRAY({producer_id:INT64,first_offset:INT64})},record_set:RECORDS})})	null	null

version:6

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition_header:{partition:INT32,error_code:INT16,high_watermark:INT64,last_stable_offset:INT64,log_start_offset:INT64,aborted_transactions:ARRAY({producer_id:INT64,first_offset:INT64})},record_set:RECORDS})})	null	null

FindCoordinatorResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
coordinator	{node_id:INT32,host:STRING,port:INT32}	null	Host and port information for the coordinator for a consumer group.

version:1

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code
error_message	NULLABLE_STRING	null	Response error message
coordinator	{node_id:INT32,host:STRING,port:INT32}	null	Host and port information for the coordinator

HeartbeatResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code

version:1

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code

InitProducerIdResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code
producer_id	INT64	null	Current producer id in use by the transactional id.
producer_epoch	INT16	null	Current epoch associated with the producer id.

JoinGroupResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
generation_id	INT32	null	The generation of the group.
group_protocol	STRING	null	The group protocol selected by the coordinator
leader_id	STRING	null	The leader of the group
member_id	STRING	null	The member id assigned by the group coordinator or null if joining for the first time.
members	ARRAY({member_id:STRING,member_metadata:BYTES})	null	null

version:1

name	type	defaultValue	docString
error_code	INT16	null	Response error code
generation_id	INT32	null	The generation of the group.
group_protocol	STRING	null	The group protocol selected by the coordinator
leader_id	STRING	null	The leader of the group
member_id	STRING	null	The member id assigned by the group coordinator or null if joining for the first time.
members	ARRAY({member_id:STRING,member_metadata:BYTES})	null	null

version:2

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code
generation_id	INT32	null	The generation of the group.
group_protocol	STRING	null	The group protocol selected by the coordinator
leader_id	STRING	null	The leader of the group
member_id	STRING	null	The member id assigned by the group coordinator or null if joining for the first time.
members	ARRAY({member_id:STRING,member_metadata:BYTES})	null	null

LeaderAndIsrResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
partitions	ARRAY({topic:STRING,partition:INT32,error_code:INT16})	null	null

version:1

name	type	defaultValue	docString
error_code	INT16	null	Response error code
partitions	ARRAY({topic:STRING,partition:INT32,error_code:INT16})	null	null

LeaveGroupResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code

version:1

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code

ListGroupsResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
groups	ARRAY({group_id:STRING,protocol_type:STRING})	null	null

version:1

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code
groups	ARRAY({group_id:STRING,protocol_type:STRING})	null	null

ListOffsetResponse

version:0

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16,offsets:ARRAY(INT64)})})	null	null

version:1

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16,timestamp:INT64,offset:INT64})})	null	null

version:2

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16,timestamp:INT64,offset:INT64})})	null	null

MetadataResponse

version:0

name	type	defaultValue	docString
brokers	ARRAY({node_id:INT32,host:STRING,port:INT32})	null	Host and port information for all brokers.
topic_metadata	ARRAY({error_code:INT16,topic:STRING,partition_metadata:ARRAY({error_code:INT16,partition:INT32,leader:INT32,replicas:ARRAY(INT32),isr:ARRAY(INT32)})})	null	null

version:1

name	type	defaultValue	docString
brokers	ARRAY({node_id:INT32,host:STRING,port:INT32,rack:NULLABLE_STRING})	null	Host and port information for all brokers.
controller_id	INT32	null	The broker id of the controller broker.
topic_metadata	ARRAY({error_code:INT16,topic:STRING,is_internal:BOOLEAN,partition_metadata:ARRAY({error_code:INT16,partition:INT32,leader:INT32,replicas:ARRAY(INT32),isr:ARRAY(INT32)})})	null	null

version:2

name	type	defaultValue	docString
brokers	ARRAY({node_id:INT32,host:STRING,port:INT32,rack:NULLABLE_STRING})	null	Host and port information for all brokers.
cluster_id	NULLABLE_STRING	null	The cluster id that this broker belongs to.
controller_id	INT32	null	The broker id of the controller broker.
topic_metadata	ARRAY({error_code:INT16,topic:STRING,is_internal:BOOLEAN,partition_metadata:ARRAY({error_code:INT16,partition:INT32,leader:INT32,replicas:ARRAY(INT32),isr:ARRAY(INT32)})})	null	null

version:3

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
brokers	ARRAY({node_id:INT32,host:STRING,port:INT32,rack:NULLABLE_STRING})	null	Host and port information for all brokers.
cluster_id	NULLABLE_STRING	null	The cluster id that this broker belongs to.
controller_id	INT32	null	The broker id of the controller broker.
topic_metadata	ARRAY({error_code:INT16,topic:STRING,is_internal:BOOLEAN,partition_metadata:ARRAY({error_code:INT16,partition:INT32,leader:INT32,replicas:ARRAY(INT32),isr:ARRAY(INT32)})})	null	null

version:4

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
brokers	ARRAY({node_id:INT32,host:STRING,port:INT32,rack:NULLABLE_STRING})	null	Host and port information for all brokers.
cluster_id	NULLABLE_STRING	null	The cluster id that this broker belongs to.
controller_id	INT32	null	The broker id of the controller broker.
topic_metadata	ARRAY({error_code:INT16,topic:STRING,is_internal:BOOLEAN,partition_metadata:ARRAY({error_code:INT16,partition:INT32,leader:INT32,replicas:ARRAY(INT32),isr:ARRAY(INT32)})})	null	null

version:5

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
brokers	ARRAY({node_id:INT32,host:STRING,port:INT32,rack:NULLABLE_STRING})	null	Host and port information for all brokers.
cluster_id	NULLABLE_STRING	null	The cluster id that this broker belongs to.
controller_id	INT32	null	The broker id of the controller broker.
topic_metadata	ARRAY({error_code:INT16,topic:STRING,is_internal:BOOLEAN,partition_metadata:ARRAY({error_code:INT16,partition:INT32,leader:INT32,replicas:ARRAY(INT32),isr:ARRAY(INT32),offline_replicas:ARRAY(INT32)})})	null	null

OffsetCommitResponse

version:0

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16})})	null	null

version:1

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16})})	null	null

version:2

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16})})	null	null

version:3

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16})})	null	null

OffsetFetchResponse

version:0

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,offset:INT64,metadata:NULLABLE_STRING,error_code:INT16})})	null	null

version:1

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,offset:INT64,metadata:NULLABLE_STRING,error_code:INT16})})	null	null

version:2

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,offset:INT64,metadata:NULLABLE_STRING,error_code:INT16})})	null	null
error_code	INT16	null	Response error code

version:3

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,offset:INT64,metadata:NULLABLE_STRING,error_code:INT16})})	null	null
error_code	INT16	null	Response error code

OffsetsForLeaderEpochResponse

version:0

name	type	defaultValue	docString
topics	ARRAY({topic:STRING,partitions:ARRAY({error_code:INT16,partition:INT32,end_offset:INT64})})	null	An array of topics for which we have leader offsets for some requested Partition Leader Epoch

ProduceResponse

version:0

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16,base_offset:INT64})})	null	null

version:1

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16,base_offset:INT64})})	null	null
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

version:2

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16,base_offset:INT64,log_append_time:INT64})})	null	null
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

version:3

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16,base_offset:INT64,log_append_time:INT64})})	null	null
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

version:4

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16,base_offset:INT64,log_append_time:INT64})})	null	null
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

version:5

name	type	defaultValue	docString
responses	ARRAY({topic:STRING,partition_responses:ARRAY({partition:INT32,error_code:INT16,base_offset:INT64,log_append_time:INT64,log_start_offset:INT64})})	null	null
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)

SaslAuthenticateResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
error_message	NULLABLE_STRING	null	Response error message
sasl_auth_bytes	BYTES	null	SASL authentication bytes from server as defined by the SASL mechanism.

SaslHandshakeResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
enabled_mechanisms	ARRAY(STRING)	null	Array of mechanisms enabled in the server.

version:1

name	type	defaultValue	docString
error_code	INT16	null	Response error code
enabled_mechanisms	ARRAY(STRING)	null	Array of mechanisms enabled in the server.

StopReplicaResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
partitions	ARRAY({topic:STRING,partition:INT32,error_code:INT16})	null	null

SyncGroupResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code
member_assignment	BYTES	null	null

version:1

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
error_code	INT16	null	Response error code
member_assignment	BYTES	null	null

TxnOffsetCommitResponse

version:0

name	type	defaultValue	docString
throttle_time_ms	INT32	0	Duration in milliseconds for which the request was throttled due to quota violation (Zero if the request did not violate any quota)
topics	ARRAY({topic:STRING,partitions:ARRAY({partition:INT32,error_code:INT16})})	null	Errors per partition from writing markers.

UpdateMetadataResponse

version:0

name	type	defaultValue	docString
error_code	INT16	null	Response error code

version:1

name	type	defaultValue	docString
error_code	INT16	null	Response error code

version:2

name	type	defaultValue	docString
error_code	INT16	null	Response error code

version:3

name	type	defaultValue	docString
error_code	INT16	null	Response error code

version:4

name	type	defaultValue	docString
error_code	INT16	null	Response error code

WriteTxnMarkersResponse

version:0

name	type	defaultValue	docString
transaction_markers	ARRAY({producer_id:INT64,topics:ARRAY({topic:STRING,partitions:ARRAY({partition:INT32,error_code:INT16})})})	null	Errors per partition from writing markers.