generated code by kafka_protocol

kpro.hrl

%% 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.