Last active
April 13, 2017 08:02
-
-
Save codesnik/1626c26dd2d9cae68923721c8c271152 to your computer and use it in GitHub Desktop.
generated code by kafka_protocol
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| %% generated code, do not edit! | |
| -ifndef(kpro_hrl). | |
| -define(kpro_hrl, true). | |
| -include("kpro_common.hrl"). | |
| -record(kpro_packet, | |
| { size :: kpro:int32() | |
| , payload :: kpro_packet_payload() | |
| }). | |
| -type kpro_packet() :: | |
| #kpro_packet{}. | |
| -type kpro_packet_payload() :: kpro_request() | |
| | kpro_response(). | |
| -record(kpro_message, | |
| { offset :: kpro:int64() | |
| , size :: kpro:int32() | |
| , crc :: kpro:int32() | |
| , magic_byte :: kpro:int8() | |
| , attributes :: kpro:int8() | |
| , key :: kpro:kafka_key() | |
| , value :: kpro:kafka_value() | |
| }). | |
| -type kpro_message() :: | |
| #kpro_message{}. | |
| -record(kpro_consumer_group_protocol_metadata, | |
| { version :: kpro:int16() | |
| , topics :: [kpro:str()] | |
| , user_data :: binary() | |
| }). | |
| -type kpro_consumer_group_protocol_metadata() :: | |
| #kpro_consumer_group_protocol_metadata{}. | |
| -record(kpro_consumer_group_member_assignment, | |
| { version :: kpro:int16() | |
| , partition_assignments :: [kpro_consumer_group_member_assignment_partition_assignment()] | |
| , user_data :: binary() | |
| }). | |
| -type kpro_consumer_group_member_assignment() :: | |
| #kpro_consumer_group_member_assignment{}. | |
| -record(kpro_consumer_group_member_assignment_partition_assignment, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro:int32()] | |
| }). | |
| -type kpro_consumer_group_member_assignment_partition_assignment() :: | |
| #kpro_consumer_group_member_assignment_partition_assignment{}. | |
| -record(kpro_request, | |
| { header :: kpro_request_header() | |
| , message :: kpro_request_message() | |
| }). | |
| -type kpro_request() :: | |
| #kpro_request{}. | |
| -record(kpro_request_header, | |
| { api_key :: kpro:int16() | |
| , api_version :: kpro:int16() | |
| , correlation_id :: kpro:int32() | |
| , client_id :: kpro:str() | |
| }). | |
| -type kpro_request_header() :: | |
| #kpro_request_header{}. | |
| -type kpro_request_message() :: kpro_produce_request_v0() | |
| | kpro_produce_request_v1() | |
| | kpro_produce_request_v2() | |
| | kpro_fetch_request_v0() | |
| | kpro_fetch_request_v1() | |
| | kpro_fetch_request_v2() | |
| | kpro_fetch_request_v3() | |
| | kpro_offsets_request_v0() | |
| | kpro_offsets_request_v1() | |
| | kpro_metadata_request_v0() | |
| | kpro_metadata_request_v1() | |
| | kpro_metadata_request_v2() | |
| | kpro_leader_and_isr_request_v0() | |
| | kpro_stop_replica_request_v0() | |
| | kpro_update_metadata_request_v0() | |
| | kpro_update_metadata_request_v1() | |
| | kpro_update_metadata_request_v2() | |
| | kpro_update_metadata_request_v3() | |
| | kpro_controlled_shutdown_request_v1() | |
| | kpro_offset_commit_request_v0() | |
| | kpro_offset_commit_request_v1() | |
| | kpro_offset_commit_request_v2() | |
| | kpro_offset_fetch_request_v0() | |
| | kpro_offset_fetch_request_v1() | |
| | kpro_offset_fetch_request_v2() | |
| | kpro_group_coordinator_request_v0() | |
| | kpro_join_group_request_v0() | |
| | kpro_join_group_request_v1() | |
| | kpro_heartbeat_request_v0() | |
| | kpro_leave_group_request_v0() | |
| | kpro_sync_group_request_v0() | |
| | kpro_describe_groups_request_v0() | |
| | kpro_list_groups_request_v0() | |
| | kpro_sasl_handshake_request_v0() | |
| | kpro_api_versions_request_v0() | |
| | kpro_create_topics_request_v0() | |
| | kpro_create_topics_request_v1() | |
| | kpro_delete_topics_request_v0(). | |
| -record(kpro_response, | |
| { header :: kpro_response_header() | |
| , message :: kpro_response_message() | |
| }). | |
| -type kpro_response() :: | |
| #kpro_response{}. | |
| -record(kpro_response_header, | |
| { correlation_id :: kpro:int32() | |
| }). | |
| -type kpro_response_header() :: | |
| #kpro_response_header{}. | |
| -type kpro_response_message() :: kpro_produce_response_v0() | |
| | kpro_produce_response_v1() | |
| | kpro_produce_response_v2() | |
| | kpro_fetch_response_v0() | |
| | kpro_fetch_response_v1() | |
| | kpro_fetch_response_v2() | |
| | kpro_fetch_response_v3() | |
| | kpro_offsets_response_v0() | |
| | kpro_offsets_response_v1() | |
| | kpro_metadata_response_v0() | |
| | kpro_metadata_response_v1() | |
| | kpro_metadata_response_v2() | |
| | kpro_leader_and_isr_response_v0() | |
| | kpro_stop_replica_response_v0() | |
| | kpro_update_metadata_response_v0() | |
| | kpro_update_metadata_response_v1() | |
| | kpro_update_metadata_response_v2() | |
| | kpro_update_metadata_response_v3() | |
| | kpro_controlled_shutdown_response_v1() | |
| | kpro_offset_commit_response_v0() | |
| | kpro_offset_commit_response_v1() | |
| | kpro_offset_commit_response_v2() | |
| | kpro_offset_fetch_response_v0() | |
| | kpro_offset_fetch_response_v1() | |
| | kpro_offset_fetch_response_v2() | |
| | kpro_group_coordinator_response_v0() | |
| | kpro_join_group_response_v0() | |
| | kpro_join_group_response_v1() | |
| | kpro_heartbeat_response_v0() | |
| | kpro_leave_group_response_v0() | |
| | kpro_sync_group_response_v0() | |
| | kpro_describe_groups_response_v0() | |
| | kpro_list_groups_response_v0() | |
| | kpro_sasl_handshake_response_v0() | |
| | kpro_api_versions_response_v0() | |
| | kpro_create_topics_response_v0() | |
| | kpro_create_topics_response_v1() | |
| | kpro_delete_topics_response_v0(). | |
| -record(kpro_produce_request_v0, | |
| { acks :: kpro:int16() | |
| , timeout :: kpro:int32() | |
| , topic_data :: [kpro_produce_request_v0_topic_data()] | |
| }). | |
| -type kpro_produce_request_v0() :: | |
| #kpro_produce_request_v0{}. | |
| -record(kpro_produce_request_v0_topic_data, | |
| { topic :: kpro:str() | |
| , data :: [kpro_produce_request_v0_data()] | |
| }). | |
| -type kpro_produce_request_v0_topic_data() :: | |
| #kpro_produce_request_v0_topic_data{}. | |
| -record(kpro_produce_request_v0_data, | |
| { partition :: kpro:int32() | |
| , record_set :: kpro:records() | |
| }). | |
| -type kpro_produce_request_v0_data() :: | |
| #kpro_produce_request_v0_data{}. | |
| -record(kpro_produce_request_v1, | |
| { acks :: kpro:int16() | |
| , timeout :: kpro:int32() | |
| , topic_data :: [kpro_produce_request_v1_topic_data()] | |
| }). | |
| -type kpro_produce_request_v1() :: | |
| #kpro_produce_request_v1{}. | |
| -record(kpro_produce_request_v1_topic_data, | |
| { topic :: kpro:str() | |
| , data :: [kpro_produce_request_v1_data()] | |
| }). | |
| -type kpro_produce_request_v1_topic_data() :: | |
| #kpro_produce_request_v1_topic_data{}. | |
| -record(kpro_produce_request_v1_data, | |
| { partition :: kpro:int32() | |
| , record_set :: kpro:records() | |
| }). | |
| -type kpro_produce_request_v1_data() :: | |
| #kpro_produce_request_v1_data{}. | |
| -record(kpro_produce_request_v2, | |
| { acks :: kpro:int16() | |
| , timeout :: kpro:int32() | |
| , topic_data :: [kpro_produce_request_v2_topic_data()] | |
| }). | |
| -type kpro_produce_request_v2() :: | |
| #kpro_produce_request_v2{}. | |
| -record(kpro_produce_request_v2_topic_data, | |
| { topic :: kpro:str() | |
| , data :: [kpro_produce_request_v2_data()] | |
| }). | |
| -type kpro_produce_request_v2_topic_data() :: | |
| #kpro_produce_request_v2_topic_data{}. | |
| -record(kpro_produce_request_v2_data, | |
| { partition :: kpro:int32() | |
| , record_set :: kpro:records() | |
| }). | |
| -type kpro_produce_request_v2_data() :: | |
| #kpro_produce_request_v2_data{}. | |
| -record(kpro_produce_response_v0, | |
| { responses :: [kpro_produce_response_v0_response()] | |
| }). | |
| -type kpro_produce_response_v0() :: | |
| #kpro_produce_response_v0{}. | |
| -record(kpro_produce_response_v0_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_produce_response_v0_partition_response()] | |
| }). | |
| -type kpro_produce_response_v0_response() :: | |
| #kpro_produce_response_v0_response{}. | |
| -record(kpro_produce_response_v0_partition_response, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| , base_offset :: kpro:int64() | |
| }). | |
| -type kpro_produce_response_v0_partition_response() :: | |
| #kpro_produce_response_v0_partition_response{}. | |
| -record(kpro_produce_response_v1, | |
| { responses :: [kpro_produce_response_v1_response()] | |
| , throttle_time_ms :: kpro:int32() | |
| }). | |
| -type kpro_produce_response_v1() :: | |
| #kpro_produce_response_v1{}. | |
| -record(kpro_produce_response_v1_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_produce_response_v1_partition_response()] | |
| }). | |
| -type kpro_produce_response_v1_response() :: | |
| #kpro_produce_response_v1_response{}. | |
| -record(kpro_produce_response_v1_partition_response, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| , base_offset :: kpro:int64() | |
| }). | |
| -type kpro_produce_response_v1_partition_response() :: | |
| #kpro_produce_response_v1_partition_response{}. | |
| -record(kpro_produce_response_v2, | |
| { responses :: [kpro_produce_response_v2_response()] | |
| , throttle_time_ms :: kpro:int32() | |
| }). | |
| -type kpro_produce_response_v2() :: | |
| #kpro_produce_response_v2{}. | |
| -record(kpro_produce_response_v2_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_produce_response_v2_partition_response()] | |
| }). | |
| -type kpro_produce_response_v2_response() :: | |
| #kpro_produce_response_v2_response{}. | |
| -record(kpro_produce_response_v2_partition_response, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| , base_offset :: kpro:int64() | |
| , log_append_time :: kpro:int64() | |
| }). | |
| -type kpro_produce_response_v2_partition_response() :: | |
| #kpro_produce_response_v2_partition_response{}. | |
| -record(kpro_fetch_request_v0, | |
| { replica_id :: kpro:int32() | |
| , max_wait_time :: kpro:int32() | |
| , min_bytes :: kpro:int32() | |
| , topics :: [kpro_fetch_request_v0_topic()] | |
| }). | |
| -type kpro_fetch_request_v0() :: | |
| #kpro_fetch_request_v0{}. | |
| -record(kpro_fetch_request_v0_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_fetch_request_v0_partition()] | |
| }). | |
| -type kpro_fetch_request_v0_topic() :: | |
| #kpro_fetch_request_v0_topic{}. | |
| -record(kpro_fetch_request_v0_partition, | |
| { partition :: kpro:int32() | |
| , fetch_offset :: kpro:int64() | |
| , max_bytes :: kpro:int32() | |
| }). | |
| -type kpro_fetch_request_v0_partition() :: | |
| #kpro_fetch_request_v0_partition{}. | |
| -record(kpro_fetch_request_v1, | |
| { replica_id :: kpro:int32() | |
| , max_wait_time :: kpro:int32() | |
| , min_bytes :: kpro:int32() | |
| , topics :: [kpro_fetch_request_v1_topic()] | |
| }). | |
| -type kpro_fetch_request_v1() :: | |
| #kpro_fetch_request_v1{}. | |
| -record(kpro_fetch_request_v1_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_fetch_request_v1_partition()] | |
| }). | |
| -type kpro_fetch_request_v1_topic() :: | |
| #kpro_fetch_request_v1_topic{}. | |
| -record(kpro_fetch_request_v1_partition, | |
| { partition :: kpro:int32() | |
| , fetch_offset :: kpro:int64() | |
| , max_bytes :: kpro:int32() | |
| }). | |
| -type kpro_fetch_request_v1_partition() :: | |
| #kpro_fetch_request_v1_partition{}. | |
| -record(kpro_fetch_request_v2, | |
| { replica_id :: kpro:int32() | |
| , max_wait_time :: kpro:int32() | |
| , min_bytes :: kpro:int32() | |
| , topics :: [kpro_fetch_request_v2_topic()] | |
| }). | |
| -type kpro_fetch_request_v2() :: | |
| #kpro_fetch_request_v2{}. | |
| -record(kpro_fetch_request_v2_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_fetch_request_v2_partition()] | |
| }). | |
| -type kpro_fetch_request_v2_topic() :: | |
| #kpro_fetch_request_v2_topic{}. | |
| -record(kpro_fetch_request_v2_partition, | |
| { partition :: kpro:int32() | |
| , fetch_offset :: kpro:int64() | |
| , max_bytes :: kpro:int32() | |
| }). | |
| -type kpro_fetch_request_v2_partition() :: | |
| #kpro_fetch_request_v2_partition{}. | |
| -record(kpro_fetch_request_v3, | |
| { replica_id :: kpro:int32() | |
| , max_wait_time :: kpro:int32() | |
| , min_bytes :: kpro:int32() | |
| , max_bytes :: kpro:int32() | |
| , topics :: [kpro_fetch_request_v3_topic()] | |
| }). | |
| -type kpro_fetch_request_v3() :: | |
| #kpro_fetch_request_v3{}. | |
| -record(kpro_fetch_request_v3_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_fetch_request_v3_partition()] | |
| }). | |
| -type kpro_fetch_request_v3_topic() :: | |
| #kpro_fetch_request_v3_topic{}. | |
| -record(kpro_fetch_request_v3_partition, | |
| { partition :: kpro:int32() | |
| , fetch_offset :: kpro:int64() | |
| , max_bytes :: kpro:int32() | |
| }). | |
| -type kpro_fetch_request_v3_partition() :: | |
| #kpro_fetch_request_v3_partition{}. | |
| -record(kpro_fetch_response_v0, | |
| { responses :: [kpro_fetch_response_v0_response()] | |
| }). | |
| -type kpro_fetch_response_v0() :: | |
| #kpro_fetch_response_v0{}. | |
| -record(kpro_fetch_response_v0_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_fetch_response_v0_partition_response()] | |
| }). | |
| -type kpro_fetch_response_v0_response() :: | |
| #kpro_fetch_response_v0_response{}. | |
| -record(kpro_fetch_response_v0_partition_response, | |
| { partition_header :: kpro_fetch_response_v0_partition_header() | |
| , record_set :: kpro:records() | |
| }). | |
| -type kpro_fetch_response_v0_partition_response() :: | |
| #kpro_fetch_response_v0_partition_response{}. | |
| -record(kpro_fetch_response_v0_partition_header, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| , high_watermark :: kpro:int64() | |
| }). | |
| -type kpro_fetch_response_v0_partition_header() :: | |
| #kpro_fetch_response_v0_partition_header{}. | |
| -record(kpro_fetch_response_v1, | |
| { throttle_time_ms :: kpro:int32() | |
| , responses :: [kpro_fetch_response_v1_response()] | |
| }). | |
| -type kpro_fetch_response_v1() :: | |
| #kpro_fetch_response_v1{}. | |
| -record(kpro_fetch_response_v1_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_fetch_response_v1_partition_response()] | |
| }). | |
| -type kpro_fetch_response_v1_response() :: | |
| #kpro_fetch_response_v1_response{}. | |
| -record(kpro_fetch_response_v1_partition_response, | |
| { partition_header :: kpro_fetch_response_v1_partition_header() | |
| , record_set :: kpro:records() | |
| }). | |
| -type kpro_fetch_response_v1_partition_response() :: | |
| #kpro_fetch_response_v1_partition_response{}. | |
| -record(kpro_fetch_response_v1_partition_header, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| , high_watermark :: kpro:int64() | |
| }). | |
| -type kpro_fetch_response_v1_partition_header() :: | |
| #kpro_fetch_response_v1_partition_header{}. | |
| -record(kpro_fetch_response_v2, | |
| { throttle_time_ms :: kpro:int32() | |
| , responses :: [kpro_fetch_response_v2_response()] | |
| }). | |
| -type kpro_fetch_response_v2() :: | |
| #kpro_fetch_response_v2{}. | |
| -record(kpro_fetch_response_v2_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_fetch_response_v2_partition_response()] | |
| }). | |
| -type kpro_fetch_response_v2_response() :: | |
| #kpro_fetch_response_v2_response{}. | |
| -record(kpro_fetch_response_v2_partition_response, | |
| { partition_header :: kpro_fetch_response_v2_partition_header() | |
| , record_set :: kpro:records() | |
| }). | |
| -type kpro_fetch_response_v2_partition_response() :: | |
| #kpro_fetch_response_v2_partition_response{}. | |
| -record(kpro_fetch_response_v2_partition_header, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| , high_watermark :: kpro:int64() | |
| }). | |
| -type kpro_fetch_response_v2_partition_header() :: | |
| #kpro_fetch_response_v2_partition_header{}. | |
| -record(kpro_fetch_response_v3, | |
| { throttle_time_ms :: kpro:int32() | |
| , responses :: [kpro_fetch_response_v3_response()] | |
| }). | |
| -type kpro_fetch_response_v3() :: | |
| #kpro_fetch_response_v3{}. | |
| -record(kpro_fetch_response_v3_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_fetch_response_v3_partition_response()] | |
| }). | |
| -type kpro_fetch_response_v3_response() :: | |
| #kpro_fetch_response_v3_response{}. | |
| -record(kpro_fetch_response_v3_partition_response, | |
| { partition_header :: kpro_fetch_response_v3_partition_header() | |
| , record_set :: kpro:records() | |
| }). | |
| -type kpro_fetch_response_v3_partition_response() :: | |
| #kpro_fetch_response_v3_partition_response{}. | |
| -record(kpro_fetch_response_v3_partition_header, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| , high_watermark :: kpro:int64() | |
| }). | |
| -type kpro_fetch_response_v3_partition_header() :: | |
| #kpro_fetch_response_v3_partition_header{}. | |
| -record(kpro_offsets_request_v0, | |
| { replica_id :: kpro:int32() | |
| , topics :: [kpro_offsets_request_v0_topic()] | |
| }). | |
| -type kpro_offsets_request_v0() :: | |
| #kpro_offsets_request_v0{}. | |
| -record(kpro_offsets_request_v0_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_offsets_request_v0_partition()] | |
| }). | |
| -type kpro_offsets_request_v0_topic() :: | |
| #kpro_offsets_request_v0_topic{}. | |
| -record(kpro_offsets_request_v0_partition, | |
| { partition :: kpro:int32() | |
| , timestamp :: kpro:int64() | |
| , max_num_offsets :: kpro:int32() | |
| }). | |
| -type kpro_offsets_request_v0_partition() :: | |
| #kpro_offsets_request_v0_partition{}. | |
| -record(kpro_offsets_request_v1, | |
| { replica_id :: kpro:int32() | |
| , topics :: [kpro_offsets_request_v1_topic()] | |
| }). | |
| -type kpro_offsets_request_v1() :: | |
| #kpro_offsets_request_v1{}. | |
| -record(kpro_offsets_request_v1_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_offsets_request_v1_partition()] | |
| }). | |
| -type kpro_offsets_request_v1_topic() :: | |
| #kpro_offsets_request_v1_topic{}. | |
| -record(kpro_offsets_request_v1_partition, | |
| { partition :: kpro:int32() | |
| , timestamp :: kpro:int64() | |
| }). | |
| -type kpro_offsets_request_v1_partition() :: | |
| #kpro_offsets_request_v1_partition{}. | |
| -record(kpro_offsets_response_v0, | |
| { responses :: [kpro_offsets_response_v0_response()] | |
| }). | |
| -type kpro_offsets_response_v0() :: | |
| #kpro_offsets_response_v0{}. | |
| -record(kpro_offsets_response_v0_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_offsets_response_v0_partition_response()] | |
| }). | |
| -type kpro_offsets_response_v0_response() :: | |
| #kpro_offsets_response_v0_response{}. | |
| -record(kpro_offsets_response_v0_partition_response, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| , offsets :: [kpro:int64()] | |
| }). | |
| -type kpro_offsets_response_v0_partition_response() :: | |
| #kpro_offsets_response_v0_partition_response{}. | |
| -record(kpro_offsets_response_v1, | |
| { responses :: [kpro_offsets_response_v1_response()] | |
| }). | |
| -type kpro_offsets_response_v1() :: | |
| #kpro_offsets_response_v1{}. | |
| -record(kpro_offsets_response_v1_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_offsets_response_v1_partition_response()] | |
| }). | |
| -type kpro_offsets_response_v1_response() :: | |
| #kpro_offsets_response_v1_response{}. | |
| -record(kpro_offsets_response_v1_partition_response, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| , timestamp :: kpro:int64() | |
| , offset :: kpro:int64() | |
| }). | |
| -type kpro_offsets_response_v1_partition_response() :: | |
| #kpro_offsets_response_v1_partition_response{}. | |
| -record(kpro_metadata_request_v0, | |
| { topics :: [kpro:str()] | |
| }). | |
| -type kpro_metadata_request_v0() :: | |
| #kpro_metadata_request_v0{}. | |
| -record(kpro_metadata_request_v1, | |
| { topics :: [kpro:str()] | |
| }). | |
| -type kpro_metadata_request_v1() :: | |
| #kpro_metadata_request_v1{}. | |
| -record(kpro_metadata_request_v2, | |
| { topics :: [kpro:str()] | |
| }). | |
| -type kpro_metadata_request_v2() :: | |
| #kpro_metadata_request_v2{}. | |
| -record(kpro_metadata_response_v0, | |
| { brokers :: [kpro_metadata_response_v0_broker()] | |
| , topic_metadata :: [kpro_metadata_response_v0_topic_metadata()] | |
| }). | |
| -type kpro_metadata_response_v0() :: | |
| #kpro_metadata_response_v0{}. | |
| -record(kpro_metadata_response_v0_broker, | |
| { node_id :: kpro:int32() | |
| , host :: kpro:str() | |
| , port :: kpro:int32() | |
| }). | |
| -type kpro_metadata_response_v0_broker() :: | |
| #kpro_metadata_response_v0_broker{}. | |
| -record(kpro_metadata_response_v0_topic_metadata, | |
| { topic_error_code :: kpro:int16() | |
| , topic :: kpro:str() | |
| , partition_metadata :: [kpro_metadata_response_v0_partition_metadata()] | |
| }). | |
| -type kpro_metadata_response_v0_topic_metadata() :: | |
| #kpro_metadata_response_v0_topic_metadata{}. | |
| -record(kpro_metadata_response_v0_partition_metadata, | |
| { partition_error_code :: kpro:int16() | |
| , partition_id :: kpro:int32() | |
| , leader :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| , isr :: [kpro:int32()] | |
| }). | |
| -type kpro_metadata_response_v0_partition_metadata() :: | |
| #kpro_metadata_response_v0_partition_metadata{}. | |
| -record(kpro_metadata_response_v1, | |
| { brokers :: [kpro_metadata_response_v1_broker()] | |
| , controller_id :: kpro:int32() | |
| , topic_metadata :: [kpro_metadata_response_v1_topic_metadata()] | |
| }). | |
| -type kpro_metadata_response_v1() :: | |
| #kpro_metadata_response_v1{}. | |
| -record(kpro_metadata_response_v1_broker, | |
| { node_id :: kpro:int32() | |
| , host :: kpro:str() | |
| , port :: kpro:int32() | |
| , rack :: kpro:str() | |
| }). | |
| -type kpro_metadata_response_v1_broker() :: | |
| #kpro_metadata_response_v1_broker{}. | |
| -record(kpro_metadata_response_v1_topic_metadata, | |
| { topic_error_code :: kpro:int16() | |
| , topic :: kpro:str() | |
| , is_internal :: boolean() | |
| , partition_metadata :: [kpro_metadata_response_v1_partition_metadata()] | |
| }). | |
| -type kpro_metadata_response_v1_topic_metadata() :: | |
| #kpro_metadata_response_v1_topic_metadata{}. | |
| -record(kpro_metadata_response_v1_partition_metadata, | |
| { partition_error_code :: kpro:int16() | |
| , partition_id :: kpro:int32() | |
| , leader :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| , isr :: [kpro:int32()] | |
| }). | |
| -type kpro_metadata_response_v1_partition_metadata() :: | |
| #kpro_metadata_response_v1_partition_metadata{}. | |
| -record(kpro_metadata_response_v2, | |
| { brokers :: [kpro_metadata_response_v2_broker()] | |
| , cluster_id :: kpro:str() | |
| , controller_id :: kpro:int32() | |
| , topic_metadata :: [kpro_metadata_response_v2_topic_metadata()] | |
| }). | |
| -type kpro_metadata_response_v2() :: | |
| #kpro_metadata_response_v2{}. | |
| -record(kpro_metadata_response_v2_broker, | |
| { node_id :: kpro:int32() | |
| , host :: kpro:str() | |
| , port :: kpro:int32() | |
| , rack :: kpro:str() | |
| }). | |
| -type kpro_metadata_response_v2_broker() :: | |
| #kpro_metadata_response_v2_broker{}. | |
| -record(kpro_metadata_response_v2_topic_metadata, | |
| { topic_error_code :: kpro:int16() | |
| , topic :: kpro:str() | |
| , is_internal :: boolean() | |
| , partition_metadata :: [kpro_metadata_response_v2_partition_metadata()] | |
| }). | |
| -type kpro_metadata_response_v2_topic_metadata() :: | |
| #kpro_metadata_response_v2_topic_metadata{}. | |
| -record(kpro_metadata_response_v2_partition_metadata, | |
| { partition_error_code :: kpro:int16() | |
| , partition_id :: kpro:int32() | |
| , leader :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| , isr :: [kpro:int32()] | |
| }). | |
| -type kpro_metadata_response_v2_partition_metadata() :: | |
| #kpro_metadata_response_v2_partition_metadata{}. | |
| -record(kpro_leader_and_isr_request_v0, | |
| { controller_id :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , partition_states :: [kpro_leader_and_isr_request_v0_partition_state()] | |
| , live_leaders :: [kpro_leader_and_isr_request_v0_live_leader()] | |
| }). | |
| -type kpro_leader_and_isr_request_v0() :: | |
| #kpro_leader_and_isr_request_v0{}. | |
| -record(kpro_leader_and_isr_request_v0_partition_state, | |
| { topic :: kpro:str() | |
| , partition :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , leader :: kpro:int32() | |
| , leader_epoch :: kpro:int32() | |
| , isr :: [kpro:int32()] | |
| , zk_version :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| }). | |
| -type kpro_leader_and_isr_request_v0_partition_state() :: | |
| #kpro_leader_and_isr_request_v0_partition_state{}. | |
| -record(kpro_leader_and_isr_request_v0_live_leader, | |
| { id :: kpro:int32() | |
| , host :: kpro:str() | |
| , port :: kpro:int32() | |
| }). | |
| -type kpro_leader_and_isr_request_v0_live_leader() :: | |
| #kpro_leader_and_isr_request_v0_live_leader{}. | |
| -record(kpro_leader_and_isr_response_v0, | |
| { error_code :: kpro:error_code() | |
| , partitions :: [kpro_leader_and_isr_response_v0_partition()] | |
| }). | |
| -type kpro_leader_and_isr_response_v0() :: | |
| #kpro_leader_and_isr_response_v0{}. | |
| -record(kpro_leader_and_isr_response_v0_partition, | |
| { topic :: kpro:str() | |
| , partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_leader_and_isr_response_v0_partition() :: | |
| #kpro_leader_and_isr_response_v0_partition{}. | |
| -record(kpro_stop_replica_request_v0, | |
| { controller_id :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , delete_partitions :: boolean() | |
| , partitions :: [kpro_stop_replica_request_v0_partition()] | |
| }). | |
| -type kpro_stop_replica_request_v0() :: | |
| #kpro_stop_replica_request_v0{}. | |
| -record(kpro_stop_replica_request_v0_partition, | |
| { topic :: kpro:str() | |
| , partition :: kpro:int32() | |
| }). | |
| -type kpro_stop_replica_request_v0_partition() :: | |
| #kpro_stop_replica_request_v0_partition{}. | |
| -record(kpro_stop_replica_response_v0, | |
| { error_code :: kpro:error_code() | |
| , partitions :: [kpro_stop_replica_response_v0_partition()] | |
| }). | |
| -type kpro_stop_replica_response_v0() :: | |
| #kpro_stop_replica_response_v0{}. | |
| -record(kpro_stop_replica_response_v0_partition, | |
| { topic :: kpro:str() | |
| , partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_stop_replica_response_v0_partition() :: | |
| #kpro_stop_replica_response_v0_partition{}. | |
| -record(kpro_update_metadata_request_v0, | |
| { controller_id :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , partition_states :: [kpro_update_metadata_request_v0_partition_state()] | |
| , live_brokers :: [kpro_update_metadata_request_v0_live_broker()] | |
| }). | |
| -type kpro_update_metadata_request_v0() :: | |
| #kpro_update_metadata_request_v0{}. | |
| -record(kpro_update_metadata_request_v0_partition_state, | |
| { topic :: kpro:str() | |
| , partition :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , leader :: kpro:int32() | |
| , leader_epoch :: kpro:int32() | |
| , isr :: [kpro:int32()] | |
| , zk_version :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| }). | |
| -type kpro_update_metadata_request_v0_partition_state() :: | |
| #kpro_update_metadata_request_v0_partition_state{}. | |
| -record(kpro_update_metadata_request_v0_live_broker, | |
| { id :: kpro:int32() | |
| , host :: kpro:str() | |
| , port :: kpro:int32() | |
| }). | |
| -type kpro_update_metadata_request_v0_live_broker() :: | |
| #kpro_update_metadata_request_v0_live_broker{}. | |
| -record(kpro_update_metadata_request_v1, | |
| { controller_id :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , partition_states :: [kpro_update_metadata_request_v1_partition_state()] | |
| , live_brokers :: [kpro_update_metadata_request_v1_live_broker()] | |
| }). | |
| -type kpro_update_metadata_request_v1() :: | |
| #kpro_update_metadata_request_v1{}. | |
| -record(kpro_update_metadata_request_v1_partition_state, | |
| { topic :: kpro:str() | |
| , partition :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , leader :: kpro:int32() | |
| , leader_epoch :: kpro:int32() | |
| , isr :: [kpro:int32()] | |
| , zk_version :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| }). | |
| -type kpro_update_metadata_request_v1_partition_state() :: | |
| #kpro_update_metadata_request_v1_partition_state{}. | |
| -record(kpro_update_metadata_request_v1_live_broker, | |
| { id :: kpro:int32() | |
| , end_points :: [kpro_update_metadata_request_v1_end_point()] | |
| }). | |
| -type kpro_update_metadata_request_v1_live_broker() :: | |
| #kpro_update_metadata_request_v1_live_broker{}. | |
| -record(kpro_update_metadata_request_v1_end_point, | |
| { port :: kpro:int32() | |
| , host :: kpro:str() | |
| , security_protocol_type :: kpro:int16() | |
| }). | |
| -type kpro_update_metadata_request_v1_end_point() :: | |
| #kpro_update_metadata_request_v1_end_point{}. | |
| -record(kpro_update_metadata_request_v2, | |
| { controller_id :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , partition_states :: [kpro_update_metadata_request_v2_partition_state()] | |
| , live_brokers :: [kpro_update_metadata_request_v2_live_broker()] | |
| }). | |
| -type kpro_update_metadata_request_v2() :: | |
| #kpro_update_metadata_request_v2{}. | |
| -record(kpro_update_metadata_request_v2_partition_state, | |
| { topic :: kpro:str() | |
| , partition :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , leader :: kpro:int32() | |
| , leader_epoch :: kpro:int32() | |
| , isr :: [kpro:int32()] | |
| , zk_version :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| }). | |
| -type kpro_update_metadata_request_v2_partition_state() :: | |
| #kpro_update_metadata_request_v2_partition_state{}. | |
| -record(kpro_update_metadata_request_v2_live_broker, | |
| { id :: kpro:int32() | |
| , end_points :: [kpro_update_metadata_request_v2_end_point()] | |
| , rack :: kpro:str() | |
| }). | |
| -type kpro_update_metadata_request_v2_live_broker() :: | |
| #kpro_update_metadata_request_v2_live_broker{}. | |
| -record(kpro_update_metadata_request_v2_end_point, | |
| { port :: kpro:int32() | |
| , host :: kpro:str() | |
| , security_protocol_type :: kpro:int16() | |
| }). | |
| -type kpro_update_metadata_request_v2_end_point() :: | |
| #kpro_update_metadata_request_v2_end_point{}. | |
| -record(kpro_update_metadata_request_v3, | |
| { controller_id :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , partition_states :: [kpro_update_metadata_request_v3_partition_state()] | |
| , live_brokers :: [kpro_update_metadata_request_v3_live_broker()] | |
| }). | |
| -type kpro_update_metadata_request_v3() :: | |
| #kpro_update_metadata_request_v3{}. | |
| -record(kpro_update_metadata_request_v3_partition_state, | |
| { topic :: kpro:str() | |
| , partition :: kpro:int32() | |
| , controller_epoch :: kpro:int32() | |
| , leader :: kpro:int32() | |
| , leader_epoch :: kpro:int32() | |
| , isr :: [kpro:int32()] | |
| , zk_version :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| }). | |
| -type kpro_update_metadata_request_v3_partition_state() :: | |
| #kpro_update_metadata_request_v3_partition_state{}. | |
| -record(kpro_update_metadata_request_v3_live_broker, | |
| { id :: kpro:int32() | |
| , end_points :: [kpro_update_metadata_request_v3_end_point()] | |
| , rack :: kpro:str() | |
| }). | |
| -type kpro_update_metadata_request_v3_live_broker() :: | |
| #kpro_update_metadata_request_v3_live_broker{}. | |
| -record(kpro_update_metadata_request_v3_end_point, | |
| { port :: kpro:int32() | |
| , host :: kpro:str() | |
| , listener_name :: kpro:str() | |
| , security_protocol_type :: kpro:int16() | |
| }). | |
| -type kpro_update_metadata_request_v3_end_point() :: | |
| #kpro_update_metadata_request_v3_end_point{}. | |
| -record(kpro_update_metadata_response_v0, | |
| { error_code :: kpro:error_code() | |
| }). | |
| -type kpro_update_metadata_response_v0() :: | |
| #kpro_update_metadata_response_v0{}. | |
| -record(kpro_update_metadata_response_v1, | |
| { error_code :: kpro:error_code() | |
| }). | |
| -type kpro_update_metadata_response_v1() :: | |
| #kpro_update_metadata_response_v1{}. | |
| -record(kpro_update_metadata_response_v2, | |
| { error_code :: kpro:error_code() | |
| }). | |
| -type kpro_update_metadata_response_v2() :: | |
| #kpro_update_metadata_response_v2{}. | |
| -record(kpro_update_metadata_response_v3, | |
| { error_code :: kpro:error_code() | |
| }). | |
| -type kpro_update_metadata_response_v3() :: | |
| #kpro_update_metadata_response_v3{}. | |
| -record(kpro_controlled_shutdown_request_v1, | |
| { broker_id :: kpro:int32() | |
| }). | |
| -type kpro_controlled_shutdown_request_v1() :: | |
| #kpro_controlled_shutdown_request_v1{}. | |
| -record(kpro_controlled_shutdown_response_v1, | |
| { error_code :: kpro:error_code() | |
| , partitions_remaining :: [kpro_controlled_shutdown_response_v1_partitions_remaining()] | |
| }). | |
| -type kpro_controlled_shutdown_response_v1() :: | |
| #kpro_controlled_shutdown_response_v1{}. | |
| -record(kpro_controlled_shutdown_response_v1_partitions_remaining, | |
| { topic :: kpro:str() | |
| , partition :: kpro:int32() | |
| }). | |
| -type kpro_controlled_shutdown_response_v1_partitions_remaining() :: | |
| #kpro_controlled_shutdown_response_v1_partitions_remaining{}. | |
| -record(kpro_offset_commit_request_v0, | |
| { group_id :: kpro:str() | |
| , topics :: [kpro_offset_commit_request_v0_topic()] | |
| }). | |
| -type kpro_offset_commit_request_v0() :: | |
| #kpro_offset_commit_request_v0{}. | |
| -record(kpro_offset_commit_request_v0_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_offset_commit_request_v0_partition()] | |
| }). | |
| -type kpro_offset_commit_request_v0_topic() :: | |
| #kpro_offset_commit_request_v0_topic{}. | |
| -record(kpro_offset_commit_request_v0_partition, | |
| { partition :: kpro:int32() | |
| , offset :: kpro:int64() | |
| , metadata :: kpro:str() | |
| }). | |
| -type kpro_offset_commit_request_v0_partition() :: | |
| #kpro_offset_commit_request_v0_partition{}. | |
| -record(kpro_offset_commit_request_v1, | |
| { group_id :: kpro:str() | |
| , group_generation_id :: kpro:int32() | |
| , member_id :: kpro:str() | |
| , topics :: [kpro_offset_commit_request_v1_topic()] | |
| }). | |
| -type kpro_offset_commit_request_v1() :: | |
| #kpro_offset_commit_request_v1{}. | |
| -record(kpro_offset_commit_request_v1_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_offset_commit_request_v1_partition()] | |
| }). | |
| -type kpro_offset_commit_request_v1_topic() :: | |
| #kpro_offset_commit_request_v1_topic{}. | |
| -record(kpro_offset_commit_request_v1_partition, | |
| { partition :: kpro:int32() | |
| , offset :: kpro:int64() | |
| , timestamp :: kpro:int64() | |
| , metadata :: kpro:str() | |
| }). | |
| -type kpro_offset_commit_request_v1_partition() :: | |
| #kpro_offset_commit_request_v1_partition{}. | |
| -record(kpro_offset_commit_request_v2, | |
| { group_id :: kpro:str() | |
| , group_generation_id :: kpro:int32() | |
| , member_id :: kpro:str() | |
| , retention_time :: kpro:int64() | |
| , topics :: [kpro_offset_commit_request_v2_topic()] | |
| }). | |
| -type kpro_offset_commit_request_v2() :: | |
| #kpro_offset_commit_request_v2{}. | |
| -record(kpro_offset_commit_request_v2_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_offset_commit_request_v2_partition()] | |
| }). | |
| -type kpro_offset_commit_request_v2_topic() :: | |
| #kpro_offset_commit_request_v2_topic{}. | |
| -record(kpro_offset_commit_request_v2_partition, | |
| { partition :: kpro:int32() | |
| , offset :: kpro:int64() | |
| , metadata :: kpro:str() | |
| }). | |
| -type kpro_offset_commit_request_v2_partition() :: | |
| #kpro_offset_commit_request_v2_partition{}. | |
| -record(kpro_offset_commit_response_v0, | |
| { responses :: [kpro_offset_commit_response_v0_response()] | |
| }). | |
| -type kpro_offset_commit_response_v0() :: | |
| #kpro_offset_commit_response_v0{}. | |
| -record(kpro_offset_commit_response_v0_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_offset_commit_response_v0_partition_response()] | |
| }). | |
| -type kpro_offset_commit_response_v0_response() :: | |
| #kpro_offset_commit_response_v0_response{}. | |
| -record(kpro_offset_commit_response_v0_partition_response, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_offset_commit_response_v0_partition_response() :: | |
| #kpro_offset_commit_response_v0_partition_response{}. | |
| -record(kpro_offset_commit_response_v1, | |
| { responses :: [kpro_offset_commit_response_v1_response()] | |
| }). | |
| -type kpro_offset_commit_response_v1() :: | |
| #kpro_offset_commit_response_v1{}. | |
| -record(kpro_offset_commit_response_v1_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_offset_commit_response_v1_partition_response()] | |
| }). | |
| -type kpro_offset_commit_response_v1_response() :: | |
| #kpro_offset_commit_response_v1_response{}. | |
| -record(kpro_offset_commit_response_v1_partition_response, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_offset_commit_response_v1_partition_response() :: | |
| #kpro_offset_commit_response_v1_partition_response{}. | |
| -record(kpro_offset_commit_response_v2, | |
| { responses :: [kpro_offset_commit_response_v2_response()] | |
| }). | |
| -type kpro_offset_commit_response_v2() :: | |
| #kpro_offset_commit_response_v2{}. | |
| -record(kpro_offset_commit_response_v2_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_offset_commit_response_v2_partition_response()] | |
| }). | |
| -type kpro_offset_commit_response_v2_response() :: | |
| #kpro_offset_commit_response_v2_response{}. | |
| -record(kpro_offset_commit_response_v2_partition_response, | |
| { partition :: kpro:int32() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_offset_commit_response_v2_partition_response() :: | |
| #kpro_offset_commit_response_v2_partition_response{}. | |
| -record(kpro_offset_fetch_request_v0, | |
| { group_id :: kpro:str() | |
| , topics :: [kpro_offset_fetch_request_v0_topic()] | |
| }). | |
| -type kpro_offset_fetch_request_v0() :: | |
| #kpro_offset_fetch_request_v0{}. | |
| -record(kpro_offset_fetch_request_v0_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_offset_fetch_request_v0_partition()] | |
| }). | |
| -type kpro_offset_fetch_request_v0_topic() :: | |
| #kpro_offset_fetch_request_v0_topic{}. | |
| -record(kpro_offset_fetch_request_v0_partition, | |
| { partition :: kpro:int32() | |
| }). | |
| -type kpro_offset_fetch_request_v0_partition() :: | |
| #kpro_offset_fetch_request_v0_partition{}. | |
| -record(kpro_offset_fetch_request_v1, | |
| { group_id :: kpro:str() | |
| , topics :: [kpro_offset_fetch_request_v1_topic()] | |
| }). | |
| -type kpro_offset_fetch_request_v1() :: | |
| #kpro_offset_fetch_request_v1{}. | |
| -record(kpro_offset_fetch_request_v1_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_offset_fetch_request_v1_partition()] | |
| }). | |
| -type kpro_offset_fetch_request_v1_topic() :: | |
| #kpro_offset_fetch_request_v1_topic{}. | |
| -record(kpro_offset_fetch_request_v1_partition, | |
| { partition :: kpro:int32() | |
| }). | |
| -type kpro_offset_fetch_request_v1_partition() :: | |
| #kpro_offset_fetch_request_v1_partition{}. | |
| -record(kpro_offset_fetch_request_v2, | |
| { group_id :: kpro:str() | |
| , topics :: [kpro_offset_fetch_request_v2_topic()] | |
| }). | |
| -type kpro_offset_fetch_request_v2() :: | |
| #kpro_offset_fetch_request_v2{}. | |
| -record(kpro_offset_fetch_request_v2_topic, | |
| { topic :: kpro:str() | |
| , partitions :: [kpro_offset_fetch_request_v2_partition()] | |
| }). | |
| -type kpro_offset_fetch_request_v2_topic() :: | |
| #kpro_offset_fetch_request_v2_topic{}. | |
| -record(kpro_offset_fetch_request_v2_partition, | |
| { partition :: kpro:int32() | |
| }). | |
| -type kpro_offset_fetch_request_v2_partition() :: | |
| #kpro_offset_fetch_request_v2_partition{}. | |
| -record(kpro_offset_fetch_response_v0, | |
| { responses :: [kpro_offset_fetch_response_v0_response()] | |
| }). | |
| -type kpro_offset_fetch_response_v0() :: | |
| #kpro_offset_fetch_response_v0{}. | |
| -record(kpro_offset_fetch_response_v0_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_offset_fetch_response_v0_partition_response()] | |
| }). | |
| -type kpro_offset_fetch_response_v0_response() :: | |
| #kpro_offset_fetch_response_v0_response{}. | |
| -record(kpro_offset_fetch_response_v0_partition_response, | |
| { partition :: kpro:int32() | |
| , offset :: kpro:int64() | |
| , metadata :: kpro:str() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_offset_fetch_response_v0_partition_response() :: | |
| #kpro_offset_fetch_response_v0_partition_response{}. | |
| -record(kpro_offset_fetch_response_v1, | |
| { responses :: [kpro_offset_fetch_response_v1_response()] | |
| }). | |
| -type kpro_offset_fetch_response_v1() :: | |
| #kpro_offset_fetch_response_v1{}. | |
| -record(kpro_offset_fetch_response_v1_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_offset_fetch_response_v1_partition_response()] | |
| }). | |
| -type kpro_offset_fetch_response_v1_response() :: | |
| #kpro_offset_fetch_response_v1_response{}. | |
| -record(kpro_offset_fetch_response_v1_partition_response, | |
| { partition :: kpro:int32() | |
| , offset :: kpro:int64() | |
| , metadata :: kpro:str() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_offset_fetch_response_v1_partition_response() :: | |
| #kpro_offset_fetch_response_v1_partition_response{}. | |
| -record(kpro_offset_fetch_response_v2, | |
| { responses :: [kpro_offset_fetch_response_v2_response()] | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_offset_fetch_response_v2() :: | |
| #kpro_offset_fetch_response_v2{}. | |
| -record(kpro_offset_fetch_response_v2_response, | |
| { topic :: kpro:str() | |
| , partition_responses :: [kpro_offset_fetch_response_v2_partition_response()] | |
| }). | |
| -type kpro_offset_fetch_response_v2_response() :: | |
| #kpro_offset_fetch_response_v2_response{}. | |
| -record(kpro_offset_fetch_response_v2_partition_response, | |
| { partition :: kpro:int32() | |
| , offset :: kpro:int64() | |
| , metadata :: kpro:str() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_offset_fetch_response_v2_partition_response() :: | |
| #kpro_offset_fetch_response_v2_partition_response{}. | |
| -record(kpro_group_coordinator_request_v0, | |
| { group_id :: kpro:str() | |
| }). | |
| -type kpro_group_coordinator_request_v0() :: | |
| #kpro_group_coordinator_request_v0{}. | |
| -record(kpro_group_coordinator_response_v0, | |
| { error_code :: kpro:error_code() | |
| , coordinator :: kpro_group_coordinator_response_v0_coordinator() | |
| }). | |
| -type kpro_group_coordinator_response_v0() :: | |
| #kpro_group_coordinator_response_v0{}. | |
| -record(kpro_group_coordinator_response_v0_coordinator, | |
| { node_id :: kpro:int32() | |
| , host :: kpro:str() | |
| , port :: kpro:int32() | |
| }). | |
| -type kpro_group_coordinator_response_v0_coordinator() :: | |
| #kpro_group_coordinator_response_v0_coordinator{}. | |
| -record(kpro_join_group_request_v0, | |
| { group_id :: kpro:str() | |
| , session_timeout :: kpro:int32() | |
| , member_id :: kpro:str() | |
| , protocol_type :: kpro:str() | |
| , group_protocols :: [kpro_join_group_request_v0_group_protocol()] | |
| }). | |
| -type kpro_join_group_request_v0() :: | |
| #kpro_join_group_request_v0{}. | |
| -record(kpro_join_group_request_v0_group_protocol, | |
| { protocol_name :: kpro:str() | |
| , protocol_metadata :: any() | |
| }). | |
| -type kpro_join_group_request_v0_group_protocol() :: | |
| #kpro_join_group_request_v0_group_protocol{}. | |
| -record(kpro_join_group_request_v1, | |
| { group_id :: kpro:str() | |
| , session_timeout :: kpro:int32() | |
| , rebalance_timeout :: kpro:int32() | |
| , member_id :: kpro:str() | |
| , protocol_type :: kpro:str() | |
| , group_protocols :: [kpro_join_group_request_v1_group_protocol()] | |
| }). | |
| -type kpro_join_group_request_v1() :: | |
| #kpro_join_group_request_v1{}. | |
| -record(kpro_join_group_request_v1_group_protocol, | |
| { protocol_name :: kpro:str() | |
| , protocol_metadata :: any() | |
| }). | |
| -type kpro_join_group_request_v1_group_protocol() :: | |
| #kpro_join_group_request_v1_group_protocol{}. | |
| -record(kpro_join_group_response_v0, | |
| { error_code :: kpro:error_code() | |
| , generation_id :: kpro:int32() | |
| , group_protocol :: kpro:str() | |
| , leader_id :: kpro:str() | |
| , member_id :: kpro:str() | |
| , members :: [kpro_join_group_response_v0_member()] | |
| }). | |
| -type kpro_join_group_response_v0() :: | |
| #kpro_join_group_response_v0{}. | |
| -record(kpro_join_group_response_v0_member, | |
| { member_id :: kpro:str() | |
| , member_metadata :: binary() | |
| }). | |
| -type kpro_join_group_response_v0_member() :: | |
| #kpro_join_group_response_v0_member{}. | |
| -record(kpro_join_group_response_v1, | |
| { error_code :: kpro:error_code() | |
| , generation_id :: kpro:int32() | |
| , group_protocol :: kpro:str() | |
| , leader_id :: kpro:str() | |
| , member_id :: kpro:str() | |
| , members :: [kpro_join_group_response_v1_member()] | |
| }). | |
| -type kpro_join_group_response_v1() :: | |
| #kpro_join_group_response_v1{}. | |
| -record(kpro_join_group_response_v1_member, | |
| { member_id :: kpro:str() | |
| , member_metadata :: binary() | |
| }). | |
| -type kpro_join_group_response_v1_member() :: | |
| #kpro_join_group_response_v1_member{}. | |
| -record(kpro_heartbeat_request_v0, | |
| { group_id :: kpro:str() | |
| , group_generation_id :: kpro:int32() | |
| , member_id :: kpro:str() | |
| }). | |
| -type kpro_heartbeat_request_v0() :: | |
| #kpro_heartbeat_request_v0{}. | |
| -record(kpro_heartbeat_response_v0, | |
| { error_code :: kpro:error_code() | |
| }). | |
| -type kpro_heartbeat_response_v0() :: | |
| #kpro_heartbeat_response_v0{}. | |
| -record(kpro_leave_group_request_v0, | |
| { group_id :: kpro:str() | |
| , member_id :: kpro:str() | |
| }). | |
| -type kpro_leave_group_request_v0() :: | |
| #kpro_leave_group_request_v0{}. | |
| -record(kpro_leave_group_response_v0, | |
| { error_code :: kpro:error_code() | |
| }). | |
| -type kpro_leave_group_response_v0() :: | |
| #kpro_leave_group_response_v0{}. | |
| -record(kpro_sync_group_request_v0, | |
| { group_id :: kpro:str() | |
| , generation_id :: kpro:int32() | |
| , member_id :: kpro:str() | |
| , group_assignment :: [kpro_sync_group_request_v0_group_assignment()] | |
| }). | |
| -type kpro_sync_group_request_v0() :: | |
| #kpro_sync_group_request_v0{}. | |
| -record(kpro_sync_group_request_v0_group_assignment, | |
| { member_id :: kpro:str() | |
| , member_assignment :: any() | |
| }). | |
| -type kpro_sync_group_request_v0_group_assignment() :: | |
| #kpro_sync_group_request_v0_group_assignment{}. | |
| -record(kpro_sync_group_response_v0, | |
| { error_code :: kpro:error_code() | |
| , member_assignment :: any() | |
| }). | |
| -type kpro_sync_group_response_v0() :: | |
| #kpro_sync_group_response_v0{}. | |
| -record(kpro_describe_groups_request_v0, | |
| { group_ids :: [kpro:str()] | |
| }). | |
| -type kpro_describe_groups_request_v0() :: | |
| #kpro_describe_groups_request_v0{}. | |
| -record(kpro_describe_groups_response_v0, | |
| { groups :: [kpro_describe_groups_response_v0_group()] | |
| }). | |
| -type kpro_describe_groups_response_v0() :: | |
| #kpro_describe_groups_response_v0{}. | |
| -record(kpro_describe_groups_response_v0_group, | |
| { error_code :: kpro:error_code() | |
| , group_id :: kpro:str() | |
| , state :: kpro:str() | |
| , protocol_type :: kpro:str() | |
| , protocol :: kpro:str() | |
| , members :: [kpro_describe_groups_response_v0_member()] | |
| }). | |
| -type kpro_describe_groups_response_v0_group() :: | |
| #kpro_describe_groups_response_v0_group{}. | |
| -record(kpro_describe_groups_response_v0_member, | |
| { member_id :: kpro:str() | |
| , client_id :: kpro:str() | |
| , client_host :: kpro:str() | |
| , member_metadata :: binary() | |
| , member_assignment :: any() | |
| }). | |
| -type kpro_describe_groups_response_v0_member() :: | |
| #kpro_describe_groups_response_v0_member{}. | |
| -record(kpro_list_groups_request_v0, | |
| { }). | |
| -type kpro_list_groups_request_v0() :: | |
| #kpro_list_groups_request_v0{}. | |
| -record(kpro_list_groups_response_v0, | |
| { error_code :: kpro:error_code() | |
| , groups :: [kpro_list_groups_response_v0_group()] | |
| }). | |
| -type kpro_list_groups_response_v0() :: | |
| #kpro_list_groups_response_v0{}. | |
| -record(kpro_list_groups_response_v0_group, | |
| { group_id :: kpro:str() | |
| , protocol_type :: kpro:str() | |
| }). | |
| -type kpro_list_groups_response_v0_group() :: | |
| #kpro_list_groups_response_v0_group{}. | |
| -record(kpro_sasl_handshake_request_v0, | |
| { mechanism :: kpro:str() | |
| }). | |
| -type kpro_sasl_handshake_request_v0() :: | |
| #kpro_sasl_handshake_request_v0{}. | |
| -record(kpro_sasl_handshake_response_v0, | |
| { error_code :: kpro:error_code() | |
| , enabled_mechanisms :: [kpro:str()] | |
| }). | |
| -type kpro_sasl_handshake_response_v0() :: | |
| #kpro_sasl_handshake_response_v0{}. | |
| -record(kpro_api_versions_request_v0, | |
| { }). | |
| -type kpro_api_versions_request_v0() :: | |
| #kpro_api_versions_request_v0{}. | |
| -record(kpro_api_versions_response_v0, | |
| { error_code :: kpro:error_code() | |
| , api_versions :: [kpro_api_versions_response_v0_api_version()] | |
| }). | |
| -type kpro_api_versions_response_v0() :: | |
| #kpro_api_versions_response_v0{}. | |
| -record(kpro_api_versions_response_v0_api_version, | |
| { api_key :: kpro:int16() | |
| , min_version :: kpro:int16() | |
| , max_version :: kpro:int16() | |
| }). | |
| -type kpro_api_versions_response_v0_api_version() :: | |
| #kpro_api_versions_response_v0_api_version{}. | |
| -record(kpro_create_topics_request_v0, | |
| { create_topic_requests :: [kpro_create_topics_request_v0_create_topic_request()] | |
| , timeout :: kpro:int32() | |
| }). | |
| -type kpro_create_topics_request_v0() :: | |
| #kpro_create_topics_request_v0{}. | |
| -record(kpro_create_topics_request_v0_create_topic_request, | |
| { topic :: kpro:str() | |
| , num_partitions :: kpro:int32() | |
| , replication_factor :: kpro:int16() | |
| , replica_assignment :: [kpro_create_topics_request_v0_replica_assignment()] | |
| , configs :: [kpro_create_topics_request_v0_config()] | |
| }). | |
| -type kpro_create_topics_request_v0_create_topic_request() :: | |
| #kpro_create_topics_request_v0_create_topic_request{}. | |
| -record(kpro_create_topics_request_v0_replica_assignment, | |
| { partition_id :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| }). | |
| -type kpro_create_topics_request_v0_replica_assignment() :: | |
| #kpro_create_topics_request_v0_replica_assignment{}. | |
| -record(kpro_create_topics_request_v0_config, | |
| { config_key :: kpro:str() | |
| , config_value :: kpro:str() | |
| }). | |
| -type kpro_create_topics_request_v0_config() :: | |
| #kpro_create_topics_request_v0_config{}. | |
| -record(kpro_create_topics_request_v1, | |
| { create_topic_requests :: [kpro_create_topics_request_v1_create_topic_request()] | |
| , timeout :: kpro:int32() | |
| , validate_only :: boolean() | |
| }). | |
| -type kpro_create_topics_request_v1() :: | |
| #kpro_create_topics_request_v1{}. | |
| -record(kpro_create_topics_request_v1_create_topic_request, | |
| { topic :: kpro:str() | |
| , num_partitions :: kpro:int32() | |
| , replication_factor :: kpro:int16() | |
| , replica_assignment :: [kpro_create_topics_request_v1_replica_assignment()] | |
| , configs :: [kpro_create_topics_request_v1_config()] | |
| }). | |
| -type kpro_create_topics_request_v1_create_topic_request() :: | |
| #kpro_create_topics_request_v1_create_topic_request{}. | |
| -record(kpro_create_topics_request_v1_replica_assignment, | |
| { partition_id :: kpro:int32() | |
| , replicas :: [kpro:int32()] | |
| }). | |
| -type kpro_create_topics_request_v1_replica_assignment() :: | |
| #kpro_create_topics_request_v1_replica_assignment{}. | |
| -record(kpro_create_topics_request_v1_config, | |
| { config_key :: kpro:str() | |
| , config_value :: kpro:str() | |
| }). | |
| -type kpro_create_topics_request_v1_config() :: | |
| #kpro_create_topics_request_v1_config{}. | |
| -record(kpro_create_topics_response_v0, | |
| { topic_errors :: [kpro_create_topics_response_v0_topic_error()] | |
| }). | |
| -type kpro_create_topics_response_v0() :: | |
| #kpro_create_topics_response_v0{}. | |
| -record(kpro_create_topics_response_v0_topic_error, | |
| { topic :: kpro:str() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_create_topics_response_v0_topic_error() :: | |
| #kpro_create_topics_response_v0_topic_error{}. | |
| -record(kpro_create_topics_response_v1, | |
| { topic_errors :: [kpro_create_topics_response_v1_topic_error()] | |
| }). | |
| -type kpro_create_topics_response_v1() :: | |
| #kpro_create_topics_response_v1{}. | |
| -record(kpro_create_topics_response_v1_topic_error, | |
| { topic :: kpro:str() | |
| , error_code :: kpro:error_code() | |
| , error_message :: kpro:str() | |
| }). | |
| -type kpro_create_topics_response_v1_topic_error() :: | |
| #kpro_create_topics_response_v1_topic_error{}. | |
| -record(kpro_delete_topics_request_v0, | |
| { topics :: [kpro:str()] | |
| , timeout :: kpro:int32() | |
| }). | |
| -type kpro_delete_topics_request_v0() :: | |
| #kpro_delete_topics_request_v0{}. | |
| -record(kpro_delete_topics_response_v0, | |
| { topic_error_codes :: [kpro_delete_topics_response_v0_topic_error_code()] | |
| }). | |
| -type kpro_delete_topics_response_v0() :: | |
| #kpro_delete_topics_response_v0{}. | |
| -record(kpro_delete_topics_response_v0_topic_error_code, | |
| { topic :: kpro:str() | |
| , error_code :: kpro:error_code() | |
| }). | |
| -type kpro_delete_topics_response_v0_topic_error_code() :: | |
| #kpro_delete_topics_response_v0_topic_error_code{}. | |
| -endif. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment