use bytes::BytesMut;
#[allow(unused_imports)]
use krabka_protocol::Encode;
#[derive(Debug, Clone, Copy)]
pub struct Case {
pub name: &'static str,
pub api_key: i16,
pub version: i16,
pub kind: Kind,
}
#[derive(Debug, Clone, Copy)]
pub enum Kind {
Request,
Response,
RequestHeader,
ResponseHeader,
}
pub const CASES: &[Case] = &[
Case {
name: "AddOffsetsToTxnRequest",
api_key: 25,
version: 0,
kind: Kind::Request,
},
Case {
name: "AddOffsetsToTxnRequest",
api_key: 25,
version: 1,
kind: Kind::Request,
},
Case {
name: "AddOffsetsToTxnRequest",
api_key: 25,
version: 2,
kind: Kind::Request,
},
Case {
name: "AddOffsetsToTxnRequest",
api_key: 25,
version: 3,
kind: Kind::Request,
},
Case {
name: "AddOffsetsToTxnRequest",
api_key: 25,
version: 4,
kind: Kind::Request,
},
Case {
name: "AddOffsetsToTxnResponse",
api_key: 25,
version: 0,
kind: Kind::Response,
},
Case {
name: "AddOffsetsToTxnResponse",
api_key: 25,
version: 1,
kind: Kind::Response,
},
Case {
name: "AddOffsetsToTxnResponse",
api_key: 25,
version: 2,
kind: Kind::Response,
},
Case {
name: "AddOffsetsToTxnResponse",
api_key: 25,
version: 3,
kind: Kind::Response,
},
Case {
name: "AddOffsetsToTxnResponse",
api_key: 25,
version: 4,
kind: Kind::Response,
},
Case {
name: "AddPartitionsToTxnRequest",
api_key: 24,
version: 0,
kind: Kind::Request,
},
Case {
name: "AddPartitionsToTxnRequest",
api_key: 24,
version: 1,
kind: Kind::Request,
},
Case {
name: "AddPartitionsToTxnRequest",
api_key: 24,
version: 2,
kind: Kind::Request,
},
Case {
name: "AddPartitionsToTxnRequest",
api_key: 24,
version: 3,
kind: Kind::Request,
},
Case {
name: "AddPartitionsToTxnRequest",
api_key: 24,
version: 4,
kind: Kind::Request,
},
Case {
name: "AddPartitionsToTxnRequest",
api_key: 24,
version: 5,
kind: Kind::Request,
},
Case {
name: "AddPartitionsToTxnResponse",
api_key: 24,
version: 0,
kind: Kind::Response,
},
Case {
name: "AddPartitionsToTxnResponse",
api_key: 24,
version: 1,
kind: Kind::Response,
},
Case {
name: "AddPartitionsToTxnResponse",
api_key: 24,
version: 2,
kind: Kind::Response,
},
Case {
name: "AddPartitionsToTxnResponse",
api_key: 24,
version: 3,
kind: Kind::Response,
},
Case {
name: "AddPartitionsToTxnResponse",
api_key: 24,
version: 4,
kind: Kind::Response,
},
Case {
name: "AddPartitionsToTxnResponse",
api_key: 24,
version: 5,
kind: Kind::Response,
},
Case {
name: "AddRaftVoterRequest",
api_key: 80,
version: 0,
kind: Kind::Request,
},
Case {
name: "AddRaftVoterRequest",
api_key: 80,
version: 1,
kind: Kind::Request,
},
Case {
name: "AddRaftVoterResponse",
api_key: 80,
version: 0,
kind: Kind::Response,
},
Case {
name: "AddRaftVoterResponse",
api_key: 80,
version: 1,
kind: Kind::Response,
},
Case {
name: "AllocateProducerIdsRequest",
api_key: 67,
version: 0,
kind: Kind::Request,
},
Case {
name: "AllocateProducerIdsResponse",
api_key: 67,
version: 0,
kind: Kind::Response,
},
Case {
name: "AlterClientQuotasRequest",
api_key: 49,
version: 0,
kind: Kind::Request,
},
Case {
name: "AlterClientQuotasRequest",
api_key: 49,
version: 1,
kind: Kind::Request,
},
Case {
name: "AlterClientQuotasResponse",
api_key: 49,
version: 0,
kind: Kind::Response,
},
Case {
name: "AlterClientQuotasResponse",
api_key: 49,
version: 1,
kind: Kind::Response,
},
Case {
name: "AlterConfigsRequest",
api_key: 33,
version: 0,
kind: Kind::Request,
},
Case {
name: "AlterConfigsRequest",
api_key: 33,
version: 1,
kind: Kind::Request,
},
Case {
name: "AlterConfigsRequest",
api_key: 33,
version: 2,
kind: Kind::Request,
},
Case {
name: "AlterConfigsResponse",
api_key: 33,
version: 0,
kind: Kind::Response,
},
Case {
name: "AlterConfigsResponse",
api_key: 33,
version: 1,
kind: Kind::Response,
},
Case {
name: "AlterConfigsResponse",
api_key: 33,
version: 2,
kind: Kind::Response,
},
Case {
name: "AlterPartitionReassignmentsRequest",
api_key: 45,
version: 0,
kind: Kind::Request,
},
Case {
name: "AlterPartitionReassignmentsRequest",
api_key: 45,
version: 1,
kind: Kind::Request,
},
Case {
name: "AlterPartitionReassignmentsResponse",
api_key: 45,
version: 0,
kind: Kind::Response,
},
Case {
name: "AlterPartitionReassignmentsResponse",
api_key: 45,
version: 1,
kind: Kind::Response,
},
Case {
name: "AlterPartitionRequest",
api_key: 56,
version: 2,
kind: Kind::Request,
},
Case {
name: "AlterPartitionRequest",
api_key: 56,
version: 3,
kind: Kind::Request,
},
Case {
name: "AlterPartitionResponse",
api_key: 56,
version: 2,
kind: Kind::Response,
},
Case {
name: "AlterPartitionResponse",
api_key: 56,
version: 3,
kind: Kind::Response,
},
Case {
name: "AlterReplicaLogDirsRequest",
api_key: 34,
version: 1,
kind: Kind::Request,
},
Case {
name: "AlterReplicaLogDirsRequest",
api_key: 34,
version: 2,
kind: Kind::Request,
},
Case {
name: "AlterReplicaLogDirsResponse",
api_key: 34,
version: 1,
kind: Kind::Response,
},
Case {
name: "AlterReplicaLogDirsResponse",
api_key: 34,
version: 2,
kind: Kind::Response,
},
Case {
name: "AlterShareGroupOffsetsRequest",
api_key: 91,
version: 0,
kind: Kind::Request,
},
Case {
name: "AlterShareGroupOffsetsResponse",
api_key: 91,
version: 0,
kind: Kind::Response,
},
Case {
name: "AlterUserScramCredentialsRequest",
api_key: 51,
version: 0,
kind: Kind::Request,
},
Case {
name: "AlterUserScramCredentialsResponse",
api_key: 51,
version: 0,
kind: Kind::Response,
},
Case {
name: "ApiVersionsRequest",
api_key: 18,
version: 0,
kind: Kind::Request,
},
Case {
name: "ApiVersionsRequest",
api_key: 18,
version: 1,
kind: Kind::Request,
},
Case {
name: "ApiVersionsRequest",
api_key: 18,
version: 2,
kind: Kind::Request,
},
Case {
name: "ApiVersionsRequest",
api_key: 18,
version: 3,
kind: Kind::Request,
},
Case {
name: "ApiVersionsRequest",
api_key: 18,
version: 4,
kind: Kind::Request,
},
Case {
name: "ApiVersionsRequest",
api_key: 18,
version: 5,
kind: Kind::Request,
},
Case {
name: "ApiVersionsResponse",
api_key: 18,
version: 0,
kind: Kind::Response,
},
Case {
name: "ApiVersionsResponse",
api_key: 18,
version: 1,
kind: Kind::Response,
},
Case {
name: "ApiVersionsResponse",
api_key: 18,
version: 2,
kind: Kind::Response,
},
Case {
name: "ApiVersionsResponse",
api_key: 18,
version: 3,
kind: Kind::Response,
},
Case {
name: "ApiVersionsResponse",
api_key: 18,
version: 4,
kind: Kind::Response,
},
Case {
name: "ApiVersionsResponse",
api_key: 18,
version: 5,
kind: Kind::Response,
},
Case {
name: "AssignReplicasToDirsRequest",
api_key: 73,
version: 0,
kind: Kind::Request,
},
Case {
name: "AssignReplicasToDirsResponse",
api_key: 73,
version: 0,
kind: Kind::Response,
},
Case {
name: "BeginQuorumEpochRequest",
api_key: 53,
version: 0,
kind: Kind::Request,
},
Case {
name: "BeginQuorumEpochRequest",
api_key: 53,
version: 1,
kind: Kind::Request,
},
Case {
name: "BeginQuorumEpochResponse",
api_key: 53,
version: 0,
kind: Kind::Response,
},
Case {
name: "BeginQuorumEpochResponse",
api_key: 53,
version: 1,
kind: Kind::Response,
},
Case {
name: "BrokerHeartbeatRequest",
api_key: 63,
version: 0,
kind: Kind::Request,
},
Case {
name: "BrokerHeartbeatRequest",
api_key: 63,
version: 1,
kind: Kind::Request,
},
Case {
name: "BrokerHeartbeatRequest",
api_key: 63,
version: 2,
kind: Kind::Request,
},
Case {
name: "BrokerHeartbeatResponse",
api_key: 63,
version: 0,
kind: Kind::Response,
},
Case {
name: "BrokerHeartbeatResponse",
api_key: 63,
version: 1,
kind: Kind::Response,
},
Case {
name: "BrokerHeartbeatResponse",
api_key: 63,
version: 2,
kind: Kind::Response,
},
Case {
name: "BrokerRegistrationRequest",
api_key: 62,
version: 0,
kind: Kind::Request,
},
Case {
name: "BrokerRegistrationRequest",
api_key: 62,
version: 1,
kind: Kind::Request,
},
Case {
name: "BrokerRegistrationRequest",
api_key: 62,
version: 2,
kind: Kind::Request,
},
Case {
name: "BrokerRegistrationRequest",
api_key: 62,
version: 3,
kind: Kind::Request,
},
Case {
name: "BrokerRegistrationRequest",
api_key: 62,
version: 4,
kind: Kind::Request,
},
Case {
name: "BrokerRegistrationResponse",
api_key: 62,
version: 0,
kind: Kind::Response,
},
Case {
name: "BrokerRegistrationResponse",
api_key: 62,
version: 1,
kind: Kind::Response,
},
Case {
name: "BrokerRegistrationResponse",
api_key: 62,
version: 2,
kind: Kind::Response,
},
Case {
name: "BrokerRegistrationResponse",
api_key: 62,
version: 3,
kind: Kind::Response,
},
Case {
name: "BrokerRegistrationResponse",
api_key: 62,
version: 4,
kind: Kind::Response,
},
Case {
name: "ConsumerGroupDescribeRequest",
api_key: 69,
version: 0,
kind: Kind::Request,
},
Case {
name: "ConsumerGroupDescribeRequest",
api_key: 69,
version: 1,
kind: Kind::Request,
},
Case {
name: "ConsumerGroupDescribeResponse",
api_key: 69,
version: 0,
kind: Kind::Response,
},
Case {
name: "ConsumerGroupDescribeResponse",
api_key: 69,
version: 1,
kind: Kind::Response,
},
Case {
name: "ConsumerGroupHeartbeatRequest",
api_key: 68,
version: 0,
kind: Kind::Request,
},
Case {
name: "ConsumerGroupHeartbeatRequest",
api_key: 68,
version: 1,
kind: Kind::Request,
},
Case {
name: "ConsumerGroupHeartbeatResponse",
api_key: 68,
version: 0,
kind: Kind::Response,
},
Case {
name: "ConsumerGroupHeartbeatResponse",
api_key: 68,
version: 1,
kind: Kind::Response,
},
Case {
name: "ControllerRegistrationRequest",
api_key: 70,
version: 0,
kind: Kind::Request,
},
Case {
name: "ControllerRegistrationResponse",
api_key: 70,
version: 0,
kind: Kind::Response,
},
Case {
name: "CreateAclsRequest",
api_key: 30,
version: 1,
kind: Kind::Request,
},
Case {
name: "CreateAclsRequest",
api_key: 30,
version: 2,
kind: Kind::Request,
},
Case {
name: "CreateAclsRequest",
api_key: 30,
version: 3,
kind: Kind::Request,
},
Case {
name: "CreateAclsResponse",
api_key: 30,
version: 1,
kind: Kind::Response,
},
Case {
name: "CreateAclsResponse",
api_key: 30,
version: 2,
kind: Kind::Response,
},
Case {
name: "CreateAclsResponse",
api_key: 30,
version: 3,
kind: Kind::Response,
},
Case {
name: "CreateDelegationTokenRequest",
api_key: 38,
version: 1,
kind: Kind::Request,
},
Case {
name: "CreateDelegationTokenRequest",
api_key: 38,
version: 2,
kind: Kind::Request,
},
Case {
name: "CreateDelegationTokenRequest",
api_key: 38,
version: 3,
kind: Kind::Request,
},
Case {
name: "CreateDelegationTokenResponse",
api_key: 38,
version: 1,
kind: Kind::Response,
},
Case {
name: "CreateDelegationTokenResponse",
api_key: 38,
version: 2,
kind: Kind::Response,
},
Case {
name: "CreateDelegationTokenResponse",
api_key: 38,
version: 3,
kind: Kind::Response,
},
Case {
name: "CreatePartitionsRequest",
api_key: 37,
version: 0,
kind: Kind::Request,
},
Case {
name: "CreatePartitionsRequest",
api_key: 37,
version: 1,
kind: Kind::Request,
},
Case {
name: "CreatePartitionsRequest",
api_key: 37,
version: 2,
kind: Kind::Request,
},
Case {
name: "CreatePartitionsRequest",
api_key: 37,
version: 3,
kind: Kind::Request,
},
Case {
name: "CreatePartitionsResponse",
api_key: 37,
version: 0,
kind: Kind::Response,
},
Case {
name: "CreatePartitionsResponse",
api_key: 37,
version: 1,
kind: Kind::Response,
},
Case {
name: "CreatePartitionsResponse",
api_key: 37,
version: 2,
kind: Kind::Response,
},
Case {
name: "CreatePartitionsResponse",
api_key: 37,
version: 3,
kind: Kind::Response,
},
Case {
name: "CreateTopicsRequest",
api_key: 19,
version: 2,
kind: Kind::Request,
},
Case {
name: "CreateTopicsRequest",
api_key: 19,
version: 3,
kind: Kind::Request,
},
Case {
name: "CreateTopicsRequest",
api_key: 19,
version: 4,
kind: Kind::Request,
},
Case {
name: "CreateTopicsRequest",
api_key: 19,
version: 5,
kind: Kind::Request,
},
Case {
name: "CreateTopicsRequest",
api_key: 19,
version: 6,
kind: Kind::Request,
},
Case {
name: "CreateTopicsRequest",
api_key: 19,
version: 7,
kind: Kind::Request,
},
Case {
name: "CreateTopicsResponse",
api_key: 19,
version: 2,
kind: Kind::Response,
},
Case {
name: "CreateTopicsResponse",
api_key: 19,
version: 3,
kind: Kind::Response,
},
Case {
name: "CreateTopicsResponse",
api_key: 19,
version: 4,
kind: Kind::Response,
},
Case {
name: "CreateTopicsResponse",
api_key: 19,
version: 5,
kind: Kind::Response,
},
Case {
name: "CreateTopicsResponse",
api_key: 19,
version: 6,
kind: Kind::Response,
},
Case {
name: "CreateTopicsResponse",
api_key: 19,
version: 7,
kind: Kind::Response,
},
Case {
name: "DeleteAclsRequest",
api_key: 31,
version: 1,
kind: Kind::Request,
},
Case {
name: "DeleteAclsRequest",
api_key: 31,
version: 2,
kind: Kind::Request,
},
Case {
name: "DeleteAclsRequest",
api_key: 31,
version: 3,
kind: Kind::Request,
},
Case {
name: "DeleteAclsResponse",
api_key: 31,
version: 1,
kind: Kind::Response,
},
Case {
name: "DeleteAclsResponse",
api_key: 31,
version: 2,
kind: Kind::Response,
},
Case {
name: "DeleteAclsResponse",
api_key: 31,
version: 3,
kind: Kind::Response,
},
Case {
name: "DeleteGroupsRequest",
api_key: 42,
version: 0,
kind: Kind::Request,
},
Case {
name: "DeleteGroupsRequest",
api_key: 42,
version: 1,
kind: Kind::Request,
},
Case {
name: "DeleteGroupsRequest",
api_key: 42,
version: 2,
kind: Kind::Request,
},
Case {
name: "DeleteGroupsRequest",
api_key: 42,
version: 3,
kind: Kind::Request,
},
Case {
name: "DeleteGroupsResponse",
api_key: 42,
version: 0,
kind: Kind::Response,
},
Case {
name: "DeleteGroupsResponse",
api_key: 42,
version: 1,
kind: Kind::Response,
},
Case {
name: "DeleteGroupsResponse",
api_key: 42,
version: 2,
kind: Kind::Response,
},
Case {
name: "DeleteGroupsResponse",
api_key: 42,
version: 3,
kind: Kind::Response,
},
Case {
name: "DeleteRecordsRequest",
api_key: 21,
version: 0,
kind: Kind::Request,
},
Case {
name: "DeleteRecordsRequest",
api_key: 21,
version: 1,
kind: Kind::Request,
},
Case {
name: "DeleteRecordsRequest",
api_key: 21,
version: 2,
kind: Kind::Request,
},
Case {
name: "DeleteRecordsResponse",
api_key: 21,
version: 0,
kind: Kind::Response,
},
Case {
name: "DeleteRecordsResponse",
api_key: 21,
version: 1,
kind: Kind::Response,
},
Case {
name: "DeleteRecordsResponse",
api_key: 21,
version: 2,
kind: Kind::Response,
},
Case {
name: "DeleteShareGroupOffsetsRequest",
api_key: 92,
version: 0,
kind: Kind::Request,
},
Case {
name: "DeleteShareGroupOffsetsResponse",
api_key: 92,
version: 0,
kind: Kind::Response,
},
Case {
name: "DeleteShareGroupStateRequest",
api_key: 86,
version: 0,
kind: Kind::Request,
},
Case {
name: "DeleteShareGroupStateResponse",
api_key: 86,
version: 0,
kind: Kind::Response,
},
Case {
name: "DeleteTopicsRequest",
api_key: 20,
version: 1,
kind: Kind::Request,
},
Case {
name: "DeleteTopicsRequest",
api_key: 20,
version: 2,
kind: Kind::Request,
},
Case {
name: "DeleteTopicsRequest",
api_key: 20,
version: 3,
kind: Kind::Request,
},
Case {
name: "DeleteTopicsRequest",
api_key: 20,
version: 4,
kind: Kind::Request,
},
Case {
name: "DeleteTopicsRequest",
api_key: 20,
version: 5,
kind: Kind::Request,
},
Case {
name: "DeleteTopicsRequest",
api_key: 20,
version: 6,
kind: Kind::Request,
},
Case {
name: "DeleteTopicsResponse",
api_key: 20,
version: 1,
kind: Kind::Response,
},
Case {
name: "DeleteTopicsResponse",
api_key: 20,
version: 2,
kind: Kind::Response,
},
Case {
name: "DeleteTopicsResponse",
api_key: 20,
version: 3,
kind: Kind::Response,
},
Case {
name: "DeleteTopicsResponse",
api_key: 20,
version: 4,
kind: Kind::Response,
},
Case {
name: "DeleteTopicsResponse",
api_key: 20,
version: 5,
kind: Kind::Response,
},
Case {
name: "DeleteTopicsResponse",
api_key: 20,
version: 6,
kind: Kind::Response,
},
Case {
name: "DescribeAclsRequest",
api_key: 29,
version: 1,
kind: Kind::Request,
},
Case {
name: "DescribeAclsRequest",
api_key: 29,
version: 2,
kind: Kind::Request,
},
Case {
name: "DescribeAclsRequest",
api_key: 29,
version: 3,
kind: Kind::Request,
},
Case {
name: "DescribeAclsResponse",
api_key: 29,
version: 1,
kind: Kind::Response,
},
Case {
name: "DescribeAclsResponse",
api_key: 29,
version: 2,
kind: Kind::Response,
},
Case {
name: "DescribeAclsResponse",
api_key: 29,
version: 3,
kind: Kind::Response,
},
Case {
name: "DescribeClientQuotasRequest",
api_key: 48,
version: 0,
kind: Kind::Request,
},
Case {
name: "DescribeClientQuotasRequest",
api_key: 48,
version: 1,
kind: Kind::Request,
},
Case {
name: "DescribeClientQuotasResponse",
api_key: 48,
version: 0,
kind: Kind::Response,
},
Case {
name: "DescribeClientQuotasResponse",
api_key: 48,
version: 1,
kind: Kind::Response,
},
Case {
name: "DescribeClusterRequest",
api_key: 60,
version: 0,
kind: Kind::Request,
},
Case {
name: "DescribeClusterRequest",
api_key: 60,
version: 1,
kind: Kind::Request,
},
Case {
name: "DescribeClusterRequest",
api_key: 60,
version: 2,
kind: Kind::Request,
},
Case {
name: "DescribeClusterResponse",
api_key: 60,
version: 0,
kind: Kind::Response,
},
Case {
name: "DescribeClusterResponse",
api_key: 60,
version: 1,
kind: Kind::Response,
},
Case {
name: "DescribeClusterResponse",
api_key: 60,
version: 2,
kind: Kind::Response,
},
Case {
name: "DescribeConfigsRequest",
api_key: 32,
version: 1,
kind: Kind::Request,
},
Case {
name: "DescribeConfigsRequest",
api_key: 32,
version: 2,
kind: Kind::Request,
},
Case {
name: "DescribeConfigsRequest",
api_key: 32,
version: 3,
kind: Kind::Request,
},
Case {
name: "DescribeConfigsRequest",
api_key: 32,
version: 4,
kind: Kind::Request,
},
Case {
name: "DescribeConfigsResponse",
api_key: 32,
version: 1,
kind: Kind::Response,
},
Case {
name: "DescribeConfigsResponse",
api_key: 32,
version: 2,
kind: Kind::Response,
},
Case {
name: "DescribeConfigsResponse",
api_key: 32,
version: 3,
kind: Kind::Response,
},
Case {
name: "DescribeConfigsResponse",
api_key: 32,
version: 4,
kind: Kind::Response,
},
Case {
name: "DescribeDelegationTokenRequest",
api_key: 41,
version: 1,
kind: Kind::Request,
},
Case {
name: "DescribeDelegationTokenRequest",
api_key: 41,
version: 2,
kind: Kind::Request,
},
Case {
name: "DescribeDelegationTokenRequest",
api_key: 41,
version: 3,
kind: Kind::Request,
},
Case {
name: "DescribeDelegationTokenResponse",
api_key: 41,
version: 1,
kind: Kind::Response,
},
Case {
name: "DescribeDelegationTokenResponse",
api_key: 41,
version: 2,
kind: Kind::Response,
},
Case {
name: "DescribeDelegationTokenResponse",
api_key: 41,
version: 3,
kind: Kind::Response,
},
Case {
name: "DescribeGroupsRequest",
api_key: 15,
version: 0,
kind: Kind::Request,
},
Case {
name: "DescribeGroupsRequest",
api_key: 15,
version: 1,
kind: Kind::Request,
},
Case {
name: "DescribeGroupsRequest",
api_key: 15,
version: 2,
kind: Kind::Request,
},
Case {
name: "DescribeGroupsRequest",
api_key: 15,
version: 3,
kind: Kind::Request,
},
Case {
name: "DescribeGroupsRequest",
api_key: 15,
version: 4,
kind: Kind::Request,
},
Case {
name: "DescribeGroupsRequest",
api_key: 15,
version: 5,
kind: Kind::Request,
},
Case {
name: "DescribeGroupsRequest",
api_key: 15,
version: 6,
kind: Kind::Request,
},
Case {
name: "DescribeGroupsResponse",
api_key: 15,
version: 0,
kind: Kind::Response,
},
Case {
name: "DescribeGroupsResponse",
api_key: 15,
version: 1,
kind: Kind::Response,
},
Case {
name: "DescribeGroupsResponse",
api_key: 15,
version: 2,
kind: Kind::Response,
},
Case {
name: "DescribeGroupsResponse",
api_key: 15,
version: 3,
kind: Kind::Response,
},
Case {
name: "DescribeGroupsResponse",
api_key: 15,
version: 4,
kind: Kind::Response,
},
Case {
name: "DescribeGroupsResponse",
api_key: 15,
version: 5,
kind: Kind::Response,
},
Case {
name: "DescribeGroupsResponse",
api_key: 15,
version: 6,
kind: Kind::Response,
},
Case {
name: "DescribeLogDirsRequest",
api_key: 35,
version: 1,
kind: Kind::Request,
},
Case {
name: "DescribeLogDirsRequest",
api_key: 35,
version: 2,
kind: Kind::Request,
},
Case {
name: "DescribeLogDirsRequest",
api_key: 35,
version: 3,
kind: Kind::Request,
},
Case {
name: "DescribeLogDirsRequest",
api_key: 35,
version: 4,
kind: Kind::Request,
},
Case {
name: "DescribeLogDirsRequest",
api_key: 35,
version: 5,
kind: Kind::Request,
},
Case {
name: "DescribeLogDirsResponse",
api_key: 35,
version: 1,
kind: Kind::Response,
},
Case {
name: "DescribeLogDirsResponse",
api_key: 35,
version: 2,
kind: Kind::Response,
},
Case {
name: "DescribeLogDirsResponse",
api_key: 35,
version: 3,
kind: Kind::Response,
},
Case {
name: "DescribeLogDirsResponse",
api_key: 35,
version: 4,
kind: Kind::Response,
},
Case {
name: "DescribeLogDirsResponse",
api_key: 35,
version: 5,
kind: Kind::Response,
},
Case {
name: "DescribeProducersRequest",
api_key: 61,
version: 0,
kind: Kind::Request,
},
Case {
name: "DescribeProducersResponse",
api_key: 61,
version: 0,
kind: Kind::Response,
},
Case {
name: "DescribeQuorumRequest",
api_key: 55,
version: 0,
kind: Kind::Request,
},
Case {
name: "DescribeQuorumRequest",
api_key: 55,
version: 1,
kind: Kind::Request,
},
Case {
name: "DescribeQuorumRequest",
api_key: 55,
version: 2,
kind: Kind::Request,
},
Case {
name: "DescribeQuorumResponse",
api_key: 55,
version: 0,
kind: Kind::Response,
},
Case {
name: "DescribeQuorumResponse",
api_key: 55,
version: 1,
kind: Kind::Response,
},
Case {
name: "DescribeQuorumResponse",
api_key: 55,
version: 2,
kind: Kind::Response,
},
Case {
name: "DescribeShareGroupOffsetsRequest",
api_key: 90,
version: 0,
kind: Kind::Request,
},
Case {
name: "DescribeShareGroupOffsetsRequest",
api_key: 90,
version: 1,
kind: Kind::Request,
},
Case {
name: "DescribeShareGroupOffsetsResponse",
api_key: 90,
version: 0,
kind: Kind::Response,
},
Case {
name: "DescribeShareGroupOffsetsResponse",
api_key: 90,
version: 1,
kind: Kind::Response,
},
Case {
name: "DescribeTopicPartitionsRequest",
api_key: 75,
version: 0,
kind: Kind::Request,
},
Case {
name: "DescribeTopicPartitionsResponse",
api_key: 75,
version: 0,
kind: Kind::Response,
},
Case {
name: "DescribeTransactionsRequest",
api_key: 65,
version: 0,
kind: Kind::Request,
},
Case {
name: "DescribeTransactionsResponse",
api_key: 65,
version: 0,
kind: Kind::Response,
},
Case {
name: "DescribeUserScramCredentialsRequest",
api_key: 50,
version: 0,
kind: Kind::Request,
},
Case {
name: "DescribeUserScramCredentialsResponse",
api_key: 50,
version: 0,
kind: Kind::Response,
},
Case {
name: "ElectLeadersRequest",
api_key: 43,
version: 0,
kind: Kind::Request,
},
Case {
name: "ElectLeadersRequest",
api_key: 43,
version: 1,
kind: Kind::Request,
},
Case {
name: "ElectLeadersRequest",
api_key: 43,
version: 2,
kind: Kind::Request,
},
Case {
name: "ElectLeadersResponse",
api_key: 43,
version: 0,
kind: Kind::Response,
},
Case {
name: "ElectLeadersResponse",
api_key: 43,
version: 1,
kind: Kind::Response,
},
Case {
name: "ElectLeadersResponse",
api_key: 43,
version: 2,
kind: Kind::Response,
},
Case {
name: "EndQuorumEpochRequest",
api_key: 54,
version: 0,
kind: Kind::Request,
},
Case {
name: "EndQuorumEpochRequest",
api_key: 54,
version: 1,
kind: Kind::Request,
},
Case {
name: "EndQuorumEpochResponse",
api_key: 54,
version: 0,
kind: Kind::Response,
},
Case {
name: "EndQuorumEpochResponse",
api_key: 54,
version: 1,
kind: Kind::Response,
},
Case {
name: "EndTxnRequest",
api_key: 26,
version: 0,
kind: Kind::Request,
},
Case {
name: "EndTxnRequest",
api_key: 26,
version: 1,
kind: Kind::Request,
},
Case {
name: "EndTxnRequest",
api_key: 26,
version: 2,
kind: Kind::Request,
},
Case {
name: "EndTxnRequest",
api_key: 26,
version: 3,
kind: Kind::Request,
},
Case {
name: "EndTxnRequest",
api_key: 26,
version: 4,
kind: Kind::Request,
},
Case {
name: "EndTxnRequest",
api_key: 26,
version: 5,
kind: Kind::Request,
},
Case {
name: "EndTxnResponse",
api_key: 26,
version: 0,
kind: Kind::Response,
},
Case {
name: "EndTxnResponse",
api_key: 26,
version: 1,
kind: Kind::Response,
},
Case {
name: "EndTxnResponse",
api_key: 26,
version: 2,
kind: Kind::Response,
},
Case {
name: "EndTxnResponse",
api_key: 26,
version: 3,
kind: Kind::Response,
},
Case {
name: "EndTxnResponse",
api_key: 26,
version: 4,
kind: Kind::Response,
},
Case {
name: "EndTxnResponse",
api_key: 26,
version: 5,
kind: Kind::Response,
},
Case {
name: "EnvelopeRequest",
api_key: 58,
version: 0,
kind: Kind::Request,
},
Case {
name: "EnvelopeResponse",
api_key: 58,
version: 0,
kind: Kind::Response,
},
Case {
name: "ExpireDelegationTokenRequest",
api_key: 40,
version: 1,
kind: Kind::Request,
},
Case {
name: "ExpireDelegationTokenRequest",
api_key: 40,
version: 2,
kind: Kind::Request,
},
Case {
name: "ExpireDelegationTokenResponse",
api_key: 40,
version: 1,
kind: Kind::Response,
},
Case {
name: "ExpireDelegationTokenResponse",
api_key: 40,
version: 2,
kind: Kind::Response,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 4,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 5,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 6,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 7,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 8,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 9,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 10,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 11,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 12,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 13,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 14,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 15,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 16,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 17,
kind: Kind::Request,
},
Case {
name: "FetchRequest",
api_key: 1,
version: 18,
kind: Kind::Request,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 4,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 5,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 6,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 7,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 8,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 9,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 10,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 11,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 12,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 13,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 14,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 15,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 16,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 17,
kind: Kind::Response,
},
Case {
name: "FetchResponse",
api_key: 1,
version: 18,
kind: Kind::Response,
},
Case {
name: "FetchSnapshotRequest",
api_key: 59,
version: 0,
kind: Kind::Request,
},
Case {
name: "FetchSnapshotRequest",
api_key: 59,
version: 1,
kind: Kind::Request,
},
Case {
name: "FetchSnapshotResponse",
api_key: 59,
version: 0,
kind: Kind::Response,
},
Case {
name: "FetchSnapshotResponse",
api_key: 59,
version: 1,
kind: Kind::Response,
},
Case {
name: "FindCoordinatorRequest",
api_key: 10,
version: 0,
kind: Kind::Request,
},
Case {
name: "FindCoordinatorRequest",
api_key: 10,
version: 1,
kind: Kind::Request,
},
Case {
name: "FindCoordinatorRequest",
api_key: 10,
version: 2,
kind: Kind::Request,
},
Case {
name: "FindCoordinatorRequest",
api_key: 10,
version: 3,
kind: Kind::Request,
},
Case {
name: "FindCoordinatorRequest",
api_key: 10,
version: 4,
kind: Kind::Request,
},
Case {
name: "FindCoordinatorRequest",
api_key: 10,
version: 5,
kind: Kind::Request,
},
Case {
name: "FindCoordinatorRequest",
api_key: 10,
version: 6,
kind: Kind::Request,
},
Case {
name: "FindCoordinatorResponse",
api_key: 10,
version: 0,
kind: Kind::Response,
},
Case {
name: "FindCoordinatorResponse",
api_key: 10,
version: 1,
kind: Kind::Response,
},
Case {
name: "FindCoordinatorResponse",
api_key: 10,
version: 2,
kind: Kind::Response,
},
Case {
name: "FindCoordinatorResponse",
api_key: 10,
version: 3,
kind: Kind::Response,
},
Case {
name: "FindCoordinatorResponse",
api_key: 10,
version: 4,
kind: Kind::Response,
},
Case {
name: "FindCoordinatorResponse",
api_key: 10,
version: 5,
kind: Kind::Response,
},
Case {
name: "FindCoordinatorResponse",
api_key: 10,
version: 6,
kind: Kind::Response,
},
Case {
name: "GetTelemetrySubscriptionsRequest",
api_key: 71,
version: 0,
kind: Kind::Request,
},
Case {
name: "GetTelemetrySubscriptionsResponse",
api_key: 71,
version: 0,
kind: Kind::Response,
},
Case {
name: "HeartbeatRequest",
api_key: 12,
version: 0,
kind: Kind::Request,
},
Case {
name: "HeartbeatRequest",
api_key: 12,
version: 1,
kind: Kind::Request,
},
Case {
name: "HeartbeatRequest",
api_key: 12,
version: 2,
kind: Kind::Request,
},
Case {
name: "HeartbeatRequest",
api_key: 12,
version: 3,
kind: Kind::Request,
},
Case {
name: "HeartbeatRequest",
api_key: 12,
version: 4,
kind: Kind::Request,
},
Case {
name: "HeartbeatResponse",
api_key: 12,
version: 0,
kind: Kind::Response,
},
Case {
name: "HeartbeatResponse",
api_key: 12,
version: 1,
kind: Kind::Response,
},
Case {
name: "HeartbeatResponse",
api_key: 12,
version: 2,
kind: Kind::Response,
},
Case {
name: "HeartbeatResponse",
api_key: 12,
version: 3,
kind: Kind::Response,
},
Case {
name: "HeartbeatResponse",
api_key: 12,
version: 4,
kind: Kind::Response,
},
Case {
name: "IncrementalAlterConfigsRequest",
api_key: 44,
version: 0,
kind: Kind::Request,
},
Case {
name: "IncrementalAlterConfigsRequest",
api_key: 44,
version: 1,
kind: Kind::Request,
},
Case {
name: "IncrementalAlterConfigsResponse",
api_key: 44,
version: 0,
kind: Kind::Response,
},
Case {
name: "IncrementalAlterConfigsResponse",
api_key: 44,
version: 1,
kind: Kind::Response,
},
Case {
name: "InitProducerIdRequest",
api_key: 22,
version: 0,
kind: Kind::Request,
},
Case {
name: "InitProducerIdRequest",
api_key: 22,
version: 1,
kind: Kind::Request,
},
Case {
name: "InitProducerIdRequest",
api_key: 22,
version: 2,
kind: Kind::Request,
},
Case {
name: "InitProducerIdRequest",
api_key: 22,
version: 3,
kind: Kind::Request,
},
Case {
name: "InitProducerIdRequest",
api_key: 22,
version: 4,
kind: Kind::Request,
},
Case {
name: "InitProducerIdRequest",
api_key: 22,
version: 5,
kind: Kind::Request,
},
Case {
name: "InitProducerIdRequest",
api_key: 22,
version: 6,
kind: Kind::Request,
},
Case {
name: "InitProducerIdResponse",
api_key: 22,
version: 0,
kind: Kind::Response,
},
Case {
name: "InitProducerIdResponse",
api_key: 22,
version: 1,
kind: Kind::Response,
},
Case {
name: "InitProducerIdResponse",
api_key: 22,
version: 2,
kind: Kind::Response,
},
Case {
name: "InitProducerIdResponse",
api_key: 22,
version: 3,
kind: Kind::Response,
},
Case {
name: "InitProducerIdResponse",
api_key: 22,
version: 4,
kind: Kind::Response,
},
Case {
name: "InitProducerIdResponse",
api_key: 22,
version: 5,
kind: Kind::Response,
},
Case {
name: "InitProducerIdResponse",
api_key: 22,
version: 6,
kind: Kind::Response,
},
Case {
name: "InitializeShareGroupStateRequest",
api_key: 83,
version: 0,
kind: Kind::Request,
},
Case {
name: "InitializeShareGroupStateResponse",
api_key: 83,
version: 0,
kind: Kind::Response,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 0,
kind: Kind::Request,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 1,
kind: Kind::Request,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 2,
kind: Kind::Request,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 3,
kind: Kind::Request,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 4,
kind: Kind::Request,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 5,
kind: Kind::Request,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 6,
kind: Kind::Request,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 7,
kind: Kind::Request,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 8,
kind: Kind::Request,
},
Case {
name: "JoinGroupRequest",
api_key: 11,
version: 9,
kind: Kind::Request,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 0,
kind: Kind::Response,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 1,
kind: Kind::Response,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 2,
kind: Kind::Response,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 3,
kind: Kind::Response,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 4,
kind: Kind::Response,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 5,
kind: Kind::Response,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 6,
kind: Kind::Response,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 7,
kind: Kind::Response,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 8,
kind: Kind::Response,
},
Case {
name: "JoinGroupResponse",
api_key: 11,
version: 9,
kind: Kind::Response,
},
Case {
name: "LeaveGroupRequest",
api_key: 13,
version: 0,
kind: Kind::Request,
},
Case {
name: "LeaveGroupRequest",
api_key: 13,
version: 1,
kind: Kind::Request,
},
Case {
name: "LeaveGroupRequest",
api_key: 13,
version: 2,
kind: Kind::Request,
},
Case {
name: "LeaveGroupRequest",
api_key: 13,
version: 3,
kind: Kind::Request,
},
Case {
name: "LeaveGroupRequest",
api_key: 13,
version: 4,
kind: Kind::Request,
},
Case {
name: "LeaveGroupRequest",
api_key: 13,
version: 5,
kind: Kind::Request,
},
Case {
name: "LeaveGroupResponse",
api_key: 13,
version: 0,
kind: Kind::Response,
},
Case {
name: "LeaveGroupResponse",
api_key: 13,
version: 1,
kind: Kind::Response,
},
Case {
name: "LeaveGroupResponse",
api_key: 13,
version: 2,
kind: Kind::Response,
},
Case {
name: "LeaveGroupResponse",
api_key: 13,
version: 3,
kind: Kind::Response,
},
Case {
name: "LeaveGroupResponse",
api_key: 13,
version: 4,
kind: Kind::Response,
},
Case {
name: "LeaveGroupResponse",
api_key: 13,
version: 5,
kind: Kind::Response,
},
Case {
name: "ListConfigResourcesRequest",
api_key: 74,
version: 0,
kind: Kind::Request,
},
Case {
name: "ListConfigResourcesRequest",
api_key: 74,
version: 1,
kind: Kind::Request,
},
Case {
name: "ListConfigResourcesResponse",
api_key: 74,
version: 0,
kind: Kind::Response,
},
Case {
name: "ListConfigResourcesResponse",
api_key: 74,
version: 1,
kind: Kind::Response,
},
Case {
name: "ListGroupsRequest",
api_key: 16,
version: 0,
kind: Kind::Request,
},
Case {
name: "ListGroupsRequest",
api_key: 16,
version: 1,
kind: Kind::Request,
},
Case {
name: "ListGroupsRequest",
api_key: 16,
version: 2,
kind: Kind::Request,
},
Case {
name: "ListGroupsRequest",
api_key: 16,
version: 3,
kind: Kind::Request,
},
Case {
name: "ListGroupsRequest",
api_key: 16,
version: 4,
kind: Kind::Request,
},
Case {
name: "ListGroupsRequest",
api_key: 16,
version: 5,
kind: Kind::Request,
},
Case {
name: "ListGroupsResponse",
api_key: 16,
version: 0,
kind: Kind::Response,
},
Case {
name: "ListGroupsResponse",
api_key: 16,
version: 1,
kind: Kind::Response,
},
Case {
name: "ListGroupsResponse",
api_key: 16,
version: 2,
kind: Kind::Response,
},
Case {
name: "ListGroupsResponse",
api_key: 16,
version: 3,
kind: Kind::Response,
},
Case {
name: "ListGroupsResponse",
api_key: 16,
version: 4,
kind: Kind::Response,
},
Case {
name: "ListGroupsResponse",
api_key: 16,
version: 5,
kind: Kind::Response,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 1,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 2,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 3,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 4,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 5,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 6,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 7,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 8,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 9,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 10,
kind: Kind::Request,
},
Case {
name: "ListOffsetsRequest",
api_key: 2,
version: 11,
kind: Kind::Request,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 1,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 2,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 3,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 4,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 5,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 6,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 7,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 8,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 9,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 10,
kind: Kind::Response,
},
Case {
name: "ListOffsetsResponse",
api_key: 2,
version: 11,
kind: Kind::Response,
},
Case {
name: "ListPartitionReassignmentsRequest",
api_key: 46,
version: 0,
kind: Kind::Request,
},
Case {
name: "ListPartitionReassignmentsResponse",
api_key: 46,
version: 0,
kind: Kind::Response,
},
Case {
name: "ListTransactionsRequest",
api_key: 66,
version: 0,
kind: Kind::Request,
},
Case {
name: "ListTransactionsRequest",
api_key: 66,
version: 1,
kind: Kind::Request,
},
Case {
name: "ListTransactionsRequest",
api_key: 66,
version: 2,
kind: Kind::Request,
},
Case {
name: "ListTransactionsResponse",
api_key: 66,
version: 0,
kind: Kind::Response,
},
Case {
name: "ListTransactionsResponse",
api_key: 66,
version: 1,
kind: Kind::Response,
},
Case {
name: "ListTransactionsResponse",
api_key: 66,
version: 2,
kind: Kind::Response,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 0,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 1,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 2,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 3,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 4,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 5,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 6,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 7,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 8,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 9,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 10,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 11,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 12,
kind: Kind::Request,
},
Case {
name: "MetadataRequest",
api_key: 3,
version: 13,
kind: Kind::Request,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 0,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 1,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 2,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 3,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 4,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 5,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 6,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 7,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 8,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 9,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 10,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 11,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 12,
kind: Kind::Response,
},
Case {
name: "MetadataResponse",
api_key: 3,
version: 13,
kind: Kind::Response,
},
Case {
name: "OffsetCommitRequest",
api_key: 8,
version: 2,
kind: Kind::Request,
},
Case {
name: "OffsetCommitRequest",
api_key: 8,
version: 3,
kind: Kind::Request,
},
Case {
name: "OffsetCommitRequest",
api_key: 8,
version: 4,
kind: Kind::Request,
},
Case {
name: "OffsetCommitRequest",
api_key: 8,
version: 5,
kind: Kind::Request,
},
Case {
name: "OffsetCommitRequest",
api_key: 8,
version: 6,
kind: Kind::Request,
},
Case {
name: "OffsetCommitRequest",
api_key: 8,
version: 7,
kind: Kind::Request,
},
Case {
name: "OffsetCommitRequest",
api_key: 8,
version: 8,
kind: Kind::Request,
},
Case {
name: "OffsetCommitRequest",
api_key: 8,
version: 9,
kind: Kind::Request,
},
Case {
name: "OffsetCommitRequest",
api_key: 8,
version: 10,
kind: Kind::Request,
},
Case {
name: "OffsetCommitResponse",
api_key: 8,
version: 2,
kind: Kind::Response,
},
Case {
name: "OffsetCommitResponse",
api_key: 8,
version: 3,
kind: Kind::Response,
},
Case {
name: "OffsetCommitResponse",
api_key: 8,
version: 4,
kind: Kind::Response,
},
Case {
name: "OffsetCommitResponse",
api_key: 8,
version: 5,
kind: Kind::Response,
},
Case {
name: "OffsetCommitResponse",
api_key: 8,
version: 6,
kind: Kind::Response,
},
Case {
name: "OffsetCommitResponse",
api_key: 8,
version: 7,
kind: Kind::Response,
},
Case {
name: "OffsetCommitResponse",
api_key: 8,
version: 8,
kind: Kind::Response,
},
Case {
name: "OffsetCommitResponse",
api_key: 8,
version: 9,
kind: Kind::Response,
},
Case {
name: "OffsetCommitResponse",
api_key: 8,
version: 10,
kind: Kind::Response,
},
Case {
name: "OffsetDeleteRequest",
api_key: 47,
version: 0,
kind: Kind::Request,
},
Case {
name: "OffsetDeleteResponse",
api_key: 47,
version: 0,
kind: Kind::Response,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 1,
kind: Kind::Request,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 2,
kind: Kind::Request,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 3,
kind: Kind::Request,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 4,
kind: Kind::Request,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 5,
kind: Kind::Request,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 6,
kind: Kind::Request,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 7,
kind: Kind::Request,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 8,
kind: Kind::Request,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 9,
kind: Kind::Request,
},
Case {
name: "OffsetFetchRequest",
api_key: 9,
version: 10,
kind: Kind::Request,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 1,
kind: Kind::Response,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 2,
kind: Kind::Response,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 3,
kind: Kind::Response,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 4,
kind: Kind::Response,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 5,
kind: Kind::Response,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 6,
kind: Kind::Response,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 7,
kind: Kind::Response,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 8,
kind: Kind::Response,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 9,
kind: Kind::Response,
},
Case {
name: "OffsetFetchResponse",
api_key: 9,
version: 10,
kind: Kind::Response,
},
Case {
name: "OffsetForLeaderEpochRequest",
api_key: 23,
version: 2,
kind: Kind::Request,
},
Case {
name: "OffsetForLeaderEpochRequest",
api_key: 23,
version: 3,
kind: Kind::Request,
},
Case {
name: "OffsetForLeaderEpochRequest",
api_key: 23,
version: 4,
kind: Kind::Request,
},
Case {
name: "OffsetForLeaderEpochResponse",
api_key: 23,
version: 2,
kind: Kind::Response,
},
Case {
name: "OffsetForLeaderEpochResponse",
api_key: 23,
version: 3,
kind: Kind::Response,
},
Case {
name: "OffsetForLeaderEpochResponse",
api_key: 23,
version: 4,
kind: Kind::Response,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 3,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 4,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 5,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 6,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 7,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 8,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 9,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 10,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 11,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 12,
kind: Kind::Request,
},
Case {
name: "ProduceRequest",
api_key: 0,
version: 13,
kind: Kind::Request,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 3,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 4,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 5,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 6,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 7,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 8,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 9,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 10,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 11,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 12,
kind: Kind::Response,
},
Case {
name: "ProduceResponse",
api_key: 0,
version: 13,
kind: Kind::Response,
},
Case {
name: "PushTelemetryRequest",
api_key: 72,
version: 0,
kind: Kind::Request,
},
Case {
name: "PushTelemetryResponse",
api_key: 72,
version: 0,
kind: Kind::Response,
},
Case {
name: "ReadShareGroupStateRequest",
api_key: 84,
version: 0,
kind: Kind::Request,
},
Case {
name: "ReadShareGroupStateResponse",
api_key: 84,
version: 0,
kind: Kind::Response,
},
Case {
name: "ReadShareGroupStateSummaryRequest",
api_key: 87,
version: 0,
kind: Kind::Request,
},
Case {
name: "ReadShareGroupStateSummaryRequest",
api_key: 87,
version: 1,
kind: Kind::Request,
},
Case {
name: "ReadShareGroupStateSummaryResponse",
api_key: 87,
version: 0,
kind: Kind::Response,
},
Case {
name: "ReadShareGroupStateSummaryResponse",
api_key: 87,
version: 1,
kind: Kind::Response,
},
Case {
name: "RemoveRaftVoterRequest",
api_key: 81,
version: 0,
kind: Kind::Request,
},
Case {
name: "RemoveRaftVoterResponse",
api_key: 81,
version: 0,
kind: Kind::Response,
},
Case {
name: "RenewDelegationTokenRequest",
api_key: 39,
version: 1,
kind: Kind::Request,
},
Case {
name: "RenewDelegationTokenRequest",
api_key: 39,
version: 2,
kind: Kind::Request,
},
Case {
name: "RenewDelegationTokenResponse",
api_key: 39,
version: 1,
kind: Kind::Response,
},
Case {
name: "RenewDelegationTokenResponse",
api_key: 39,
version: 2,
kind: Kind::Response,
},
Case {
name: "RequestHeader",
api_key: 0,
version: 1,
kind: Kind::RequestHeader,
},
Case {
name: "RequestHeader",
api_key: 0,
version: 2,
kind: Kind::RequestHeader,
},
Case {
name: "ResponseHeader",
api_key: 0,
version: 0,
kind: Kind::ResponseHeader,
},
Case {
name: "ResponseHeader",
api_key: 0,
version: 1,
kind: Kind::ResponseHeader,
},
Case {
name: "SaslAuthenticateRequest",
api_key: 36,
version: 0,
kind: Kind::Request,
},
Case {
name: "SaslAuthenticateRequest",
api_key: 36,
version: 1,
kind: Kind::Request,
},
Case {
name: "SaslAuthenticateRequest",
api_key: 36,
version: 2,
kind: Kind::Request,
},
Case {
name: "SaslAuthenticateResponse",
api_key: 36,
version: 0,
kind: Kind::Response,
},
Case {
name: "SaslAuthenticateResponse",
api_key: 36,
version: 1,
kind: Kind::Response,
},
Case {
name: "SaslAuthenticateResponse",
api_key: 36,
version: 2,
kind: Kind::Response,
},
Case {
name: "SaslHandshakeRequest",
api_key: 17,
version: 0,
kind: Kind::Request,
},
Case {
name: "SaslHandshakeRequest",
api_key: 17,
version: 1,
kind: Kind::Request,
},
Case {
name: "SaslHandshakeResponse",
api_key: 17,
version: 0,
kind: Kind::Response,
},
Case {
name: "SaslHandshakeResponse",
api_key: 17,
version: 1,
kind: Kind::Response,
},
Case {
name: "ShareAcknowledgeRequest",
api_key: 79,
version: 1,
kind: Kind::Request,
},
Case {
name: "ShareAcknowledgeRequest",
api_key: 79,
version: 2,
kind: Kind::Request,
},
Case {
name: "ShareAcknowledgeResponse",
api_key: 79,
version: 1,
kind: Kind::Response,
},
Case {
name: "ShareAcknowledgeResponse",
api_key: 79,
version: 2,
kind: Kind::Response,
},
Case {
name: "ShareFetchRequest",
api_key: 78,
version: 1,
kind: Kind::Request,
},
Case {
name: "ShareFetchRequest",
api_key: 78,
version: 2,
kind: Kind::Request,
},
Case {
name: "ShareFetchResponse",
api_key: 78,
version: 1,
kind: Kind::Response,
},
Case {
name: "ShareFetchResponse",
api_key: 78,
version: 2,
kind: Kind::Response,
},
Case {
name: "ShareGroupDescribeRequest",
api_key: 77,
version: 1,
kind: Kind::Request,
},
Case {
name: "ShareGroupDescribeResponse",
api_key: 77,
version: 1,
kind: Kind::Response,
},
Case {
name: "ShareGroupHeartbeatRequest",
api_key: 76,
version: 1,
kind: Kind::Request,
},
Case {
name: "ShareGroupHeartbeatResponse",
api_key: 76,
version: 1,
kind: Kind::Response,
},
Case {
name: "StreamsGroupDescribeRequest",
api_key: 89,
version: 0,
kind: Kind::Request,
},
Case {
name: "StreamsGroupDescribeRequest",
api_key: 89,
version: 1,
kind: Kind::Request,
},
Case {
name: "StreamsGroupDescribeResponse",
api_key: 89,
version: 0,
kind: Kind::Response,
},
Case {
name: "StreamsGroupDescribeResponse",
api_key: 89,
version: 1,
kind: Kind::Response,
},
Case {
name: "StreamsGroupHeartbeatRequest",
api_key: 88,
version: 0,
kind: Kind::Request,
},
Case {
name: "StreamsGroupHeartbeatRequest",
api_key: 88,
version: 1,
kind: Kind::Request,
},
Case {
name: "StreamsGroupHeartbeatResponse",
api_key: 88,
version: 0,
kind: Kind::Response,
},
Case {
name: "StreamsGroupHeartbeatResponse",
api_key: 88,
version: 1,
kind: Kind::Response,
},
Case {
name: "StreamsGroupTopologyDescriptionUpdateRequest",
api_key: 93,
version: 0,
kind: Kind::Request,
},
Case {
name: "StreamsGroupTopologyDescriptionUpdateResponse",
api_key: 93,
version: 0,
kind: Kind::Response,
},
Case {
name: "SyncGroupRequest",
api_key: 14,
version: 0,
kind: Kind::Request,
},
Case {
name: "SyncGroupRequest",
api_key: 14,
version: 1,
kind: Kind::Request,
},
Case {
name: "SyncGroupRequest",
api_key: 14,
version: 2,
kind: Kind::Request,
},
Case {
name: "SyncGroupRequest",
api_key: 14,
version: 3,
kind: Kind::Request,
},
Case {
name: "SyncGroupRequest",
api_key: 14,
version: 4,
kind: Kind::Request,
},
Case {
name: "SyncGroupRequest",
api_key: 14,
version: 5,
kind: Kind::Request,
},
Case {
name: "SyncGroupResponse",
api_key: 14,
version: 0,
kind: Kind::Response,
},
Case {
name: "SyncGroupResponse",
api_key: 14,
version: 1,
kind: Kind::Response,
},
Case {
name: "SyncGroupResponse",
api_key: 14,
version: 2,
kind: Kind::Response,
},
Case {
name: "SyncGroupResponse",
api_key: 14,
version: 3,
kind: Kind::Response,
},
Case {
name: "SyncGroupResponse",
api_key: 14,
version: 4,
kind: Kind::Response,
},
Case {
name: "SyncGroupResponse",
api_key: 14,
version: 5,
kind: Kind::Response,
},
Case {
name: "TxnOffsetCommitRequest",
api_key: 28,
version: 0,
kind: Kind::Request,
},
Case {
name: "TxnOffsetCommitRequest",
api_key: 28,
version: 1,
kind: Kind::Request,
},
Case {
name: "TxnOffsetCommitRequest",
api_key: 28,
version: 2,
kind: Kind::Request,
},
Case {
name: "TxnOffsetCommitRequest",
api_key: 28,
version: 3,
kind: Kind::Request,
},
Case {
name: "TxnOffsetCommitRequest",
api_key: 28,
version: 4,
kind: Kind::Request,
},
Case {
name: "TxnOffsetCommitRequest",
api_key: 28,
version: 5,
kind: Kind::Request,
},
Case {
name: "TxnOffsetCommitRequest",
api_key: 28,
version: 6,
kind: Kind::Request,
},
Case {
name: "TxnOffsetCommitResponse",
api_key: 28,
version: 0,
kind: Kind::Response,
},
Case {
name: "TxnOffsetCommitResponse",
api_key: 28,
version: 1,
kind: Kind::Response,
},
Case {
name: "TxnOffsetCommitResponse",
api_key: 28,
version: 2,
kind: Kind::Response,
},
Case {
name: "TxnOffsetCommitResponse",
api_key: 28,
version: 3,
kind: Kind::Response,
},
Case {
name: "TxnOffsetCommitResponse",
api_key: 28,
version: 4,
kind: Kind::Response,
},
Case {
name: "TxnOffsetCommitResponse",
api_key: 28,
version: 5,
kind: Kind::Response,
},
Case {
name: "TxnOffsetCommitResponse",
api_key: 28,
version: 6,
kind: Kind::Response,
},
Case {
name: "UnregisterBrokerRequest",
api_key: 64,
version: 0,
kind: Kind::Request,
},
Case {
name: "UnregisterBrokerResponse",
api_key: 64,
version: 0,
kind: Kind::Response,
},
Case {
name: "UnregisterControllerRequest",
api_key: 94,
version: 0,
kind: Kind::Request,
},
Case {
name: "UnregisterControllerResponse",
api_key: 94,
version: 0,
kind: Kind::Response,
},
Case {
name: "UpdateFeaturesRequest",
api_key: 57,
version: 0,
kind: Kind::Request,
},
Case {
name: "UpdateFeaturesRequest",
api_key: 57,
version: 1,
kind: Kind::Request,
},
Case {
name: "UpdateFeaturesRequest",
api_key: 57,
version: 2,
kind: Kind::Request,
},
Case {
name: "UpdateFeaturesResponse",
api_key: 57,
version: 0,
kind: Kind::Response,
},
Case {
name: "UpdateFeaturesResponse",
api_key: 57,
version: 1,
kind: Kind::Response,
},
Case {
name: "UpdateFeaturesResponse",
api_key: 57,
version: 2,
kind: Kind::Response,
},
Case {
name: "UpdateRaftVoterRequest",
api_key: 82,
version: 0,
kind: Kind::Request,
},
Case {
name: "UpdateRaftVoterResponse",
api_key: 82,
version: 0,
kind: Kind::Response,
},
Case {
name: "VoteRequest",
api_key: 52,
version: 0,
kind: Kind::Request,
},
Case {
name: "VoteRequest",
api_key: 52,
version: 1,
kind: Kind::Request,
},
Case {
name: "VoteRequest",
api_key: 52,
version: 2,
kind: Kind::Request,
},
Case {
name: "VoteResponse",
api_key: 52,
version: 0,
kind: Kind::Response,
},
Case {
name: "VoteResponse",
api_key: 52,
version: 1,
kind: Kind::Response,
},
Case {
name: "VoteResponse",
api_key: 52,
version: 2,
kind: Kind::Response,
},
Case {
name: "WriteShareGroupStateRequest",
api_key: 85,
version: 0,
kind: Kind::Request,
},
Case {
name: "WriteShareGroupStateRequest",
api_key: 85,
version: 1,
kind: Kind::Request,
},
Case {
name: "WriteShareGroupStateResponse",
api_key: 85,
version: 0,
kind: Kind::Response,
},
Case {
name: "WriteShareGroupStateResponse",
api_key: 85,
version: 1,
kind: Kind::Response,
},
Case {
name: "WriteTxnMarkersRequest",
api_key: 27,
version: 1,
kind: Kind::Request,
},
Case {
name: "WriteTxnMarkersRequest",
api_key: 27,
version: 2,
kind: Kind::Request,
},
Case {
name: "WriteTxnMarkersResponse",
api_key: 27,
version: 1,
kind: Kind::Response,
},
Case {
name: "WriteTxnMarkersResponse",
api_key: 27,
version: 2,
kind: Kind::Response,
},
];
fn encode_default_0(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"AddOffsetsToTxnRequest" => {
let msg =
krabka_protocol::owned::add_offsets_to_txn_request::AddOffsetsToTxnRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddOffsetsToTxnResponse" => {
let msg = krabka_protocol::owned::add_offsets_to_txn_response::AddOffsetsToTxnResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddPartitionsToTxnRequest" => {
let msg = krabka_protocol::owned::add_partitions_to_txn_request::AddPartitionsToTxnRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddPartitionsToTxnResponse" => {
let msg = krabka_protocol::owned::add_partitions_to_txn_response::AddPartitionsToTxnResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddRaftVoterRequest" => {
let msg =
krabka_protocol::owned::add_raft_voter_request::AddRaftVoterRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddRaftVoterResponse" => {
let msg =
krabka_protocol::owned::add_raft_voter_response::AddRaftVoterResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AllocateProducerIdsRequest" => {
let msg = krabka_protocol::owned::allocate_producer_ids_request::AllocateProducerIdsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AllocateProducerIdsResponse" => {
let msg = krabka_protocol::owned::allocate_producer_ids_response::AllocateProducerIdsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_1(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"AlterClientQuotasRequest" => {
let msg = krabka_protocol::owned::alter_client_quotas_request::AlterClientQuotasRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterClientQuotasResponse" => {
let msg = krabka_protocol::owned::alter_client_quotas_response::AlterClientQuotasResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterConfigsRequest" => {
let msg = krabka_protocol::owned::alter_configs_request::AlterConfigsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterConfigsResponse" => {
let msg =
krabka_protocol::owned::alter_configs_response::AlterConfigsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterPartitionReassignmentsRequest" => {
let msg = krabka_protocol::owned::alter_partition_reassignments_request::AlterPartitionReassignmentsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterPartitionReassignmentsResponse" => {
let msg = krabka_protocol::owned::alter_partition_reassignments_response::AlterPartitionReassignmentsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterPartitionRequest" => {
let msg =
krabka_protocol::owned::alter_partition_request::AlterPartitionRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterPartitionResponse" => {
let msg =
krabka_protocol::owned::alter_partition_response::AlterPartitionResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_2(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"AlterReplicaLogDirsRequest" => {
let msg = krabka_protocol::owned::alter_replica_log_dirs_request::AlterReplicaLogDirsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterReplicaLogDirsResponse" => {
let msg = krabka_protocol::owned::alter_replica_log_dirs_response::AlterReplicaLogDirsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterShareGroupOffsetsRequest" => {
let msg = krabka_protocol::owned::alter_share_group_offsets_request::AlterShareGroupOffsetsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterShareGroupOffsetsResponse" => {
let msg = krabka_protocol::owned::alter_share_group_offsets_response::AlterShareGroupOffsetsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterUserScramCredentialsRequest" => {
let msg = krabka_protocol::owned::alter_user_scram_credentials_request::AlterUserScramCredentialsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterUserScramCredentialsResponse" => {
let msg = krabka_protocol::owned::alter_user_scram_credentials_response::AlterUserScramCredentialsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ApiVersionsRequest" => {
let msg = krabka_protocol::owned::api_versions_request::ApiVersionsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ApiVersionsResponse" => {
let msg = krabka_protocol::owned::api_versions_response::ApiVersionsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_3(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"AssignReplicasToDirsRequest" => {
let msg = krabka_protocol::owned::assign_replicas_to_dirs_request::AssignReplicasToDirsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AssignReplicasToDirsResponse" => {
let msg = krabka_protocol::owned::assign_replicas_to_dirs_response::AssignReplicasToDirsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BeginQuorumEpochRequest" => {
let msg = krabka_protocol::owned::begin_quorum_epoch_request::BeginQuorumEpochRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BeginQuorumEpochResponse" => {
let msg = krabka_protocol::owned::begin_quorum_epoch_response::BeginQuorumEpochResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BrokerHeartbeatRequest" => {
let msg =
krabka_protocol::owned::broker_heartbeat_request::BrokerHeartbeatRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BrokerHeartbeatResponse" => {
let msg =
krabka_protocol::owned::broker_heartbeat_response::BrokerHeartbeatResponse::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BrokerRegistrationRequest" => {
let msg = krabka_protocol::owned::broker_registration_request::BrokerRegistrationRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BrokerRegistrationResponse" => {
let msg = krabka_protocol::owned::broker_registration_response::BrokerRegistrationResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_4(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"ConsumerGroupDescribeRequest" => {
let msg = krabka_protocol::owned::consumer_group_describe_request::ConsumerGroupDescribeRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ConsumerGroupDescribeResponse" => {
let msg = krabka_protocol::owned::consumer_group_describe_response::ConsumerGroupDescribeResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ConsumerGroupHeartbeatRequest" => {
let msg = krabka_protocol::owned::consumer_group_heartbeat_request::ConsumerGroupHeartbeatRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ConsumerGroupHeartbeatResponse" => {
let msg = krabka_protocol::owned::consumer_group_heartbeat_response::ConsumerGroupHeartbeatResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ControllerRegistrationRequest" => {
let msg = krabka_protocol::owned::controller_registration_request::ControllerRegistrationRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ControllerRegistrationResponse" => {
let msg = krabka_protocol::owned::controller_registration_response::ControllerRegistrationResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateAclsRequest" => {
let msg = krabka_protocol::owned::create_acls_request::CreateAclsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateAclsResponse" => {
let msg = krabka_protocol::owned::create_acls_response::CreateAclsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_5(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"CreateDelegationTokenRequest" => {
let msg = krabka_protocol::owned::create_delegation_token_request::CreateDelegationTokenRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateDelegationTokenResponse" => {
let msg = krabka_protocol::owned::create_delegation_token_response::CreateDelegationTokenResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreatePartitionsRequest" => {
let msg =
krabka_protocol::owned::create_partitions_request::CreatePartitionsRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreatePartitionsResponse" => {
let msg = krabka_protocol::owned::create_partitions_response::CreatePartitionsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateTopicsRequest" => {
let msg = krabka_protocol::owned::create_topics_request::CreateTopicsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateTopicsResponse" => {
let msg =
krabka_protocol::owned::create_topics_response::CreateTopicsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteAclsRequest" => {
let msg = krabka_protocol::owned::delete_acls_request::DeleteAclsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteAclsResponse" => {
let msg = krabka_protocol::owned::delete_acls_response::DeleteAclsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_6(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"DeleteGroupsRequest" => {
let msg = krabka_protocol::owned::delete_groups_request::DeleteGroupsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteGroupsResponse" => {
let msg =
krabka_protocol::owned::delete_groups_response::DeleteGroupsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteRecordsRequest" => {
let msg =
krabka_protocol::owned::delete_records_request::DeleteRecordsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteRecordsResponse" => {
let msg =
krabka_protocol::owned::delete_records_response::DeleteRecordsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteShareGroupOffsetsRequest" => {
let msg = krabka_protocol::owned::delete_share_group_offsets_request::DeleteShareGroupOffsetsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteShareGroupOffsetsResponse" => {
let msg = krabka_protocol::owned::delete_share_group_offsets_response::DeleteShareGroupOffsetsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteShareGroupStateRequest" => {
let msg = krabka_protocol::owned::delete_share_group_state_request::DeleteShareGroupStateRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteShareGroupStateResponse" => {
let msg = krabka_protocol::owned::delete_share_group_state_response::DeleteShareGroupStateResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_7(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"DeleteTopicsRequest" => {
let msg = krabka_protocol::owned::delete_topics_request::DeleteTopicsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteTopicsResponse" => {
let msg =
krabka_protocol::owned::delete_topics_response::DeleteTopicsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeAclsRequest" => {
let msg = krabka_protocol::owned::describe_acls_request::DescribeAclsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeAclsResponse" => {
let msg =
krabka_protocol::owned::describe_acls_response::DescribeAclsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeClientQuotasRequest" => {
let msg = krabka_protocol::owned::describe_client_quotas_request::DescribeClientQuotasRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeClientQuotasResponse" => {
let msg = krabka_protocol::owned::describe_client_quotas_response::DescribeClientQuotasResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeClusterRequest" => {
let msg =
krabka_protocol::owned::describe_cluster_request::DescribeClusterRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeClusterResponse" => {
let msg =
krabka_protocol::owned::describe_cluster_response::DescribeClusterResponse::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_8(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"DescribeConfigsRequest" => {
let msg =
krabka_protocol::owned::describe_configs_request::DescribeConfigsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeConfigsResponse" => {
let msg =
krabka_protocol::owned::describe_configs_response::DescribeConfigsResponse::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeDelegationTokenRequest" => {
let msg = krabka_protocol::owned::describe_delegation_token_request::DescribeDelegationTokenRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeDelegationTokenResponse" => {
let msg = krabka_protocol::owned::describe_delegation_token_response::DescribeDelegationTokenResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeGroupsRequest" => {
let msg =
krabka_protocol::owned::describe_groups_request::DescribeGroupsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeGroupsResponse" => {
let msg =
krabka_protocol::owned::describe_groups_response::DescribeGroupsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeLogDirsRequest" => {
let msg =
krabka_protocol::owned::describe_log_dirs_request::DescribeLogDirsRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeLogDirsResponse" => {
let msg = krabka_protocol::owned::describe_log_dirs_response::DescribeLogDirsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_9(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"DescribeProducersRequest" => {
let msg = krabka_protocol::owned::describe_producers_request::DescribeProducersRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeProducersResponse" => {
let msg = krabka_protocol::owned::describe_producers_response::DescribeProducersResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeQuorumRequest" => {
let msg =
krabka_protocol::owned::describe_quorum_request::DescribeQuorumRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeQuorumResponse" => {
let msg =
krabka_protocol::owned::describe_quorum_response::DescribeQuorumResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeShareGroupOffsetsRequest" => {
let msg = krabka_protocol::owned::describe_share_group_offsets_request::DescribeShareGroupOffsetsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeShareGroupOffsetsResponse" => {
let msg = krabka_protocol::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeTopicPartitionsRequest" => {
let msg = krabka_protocol::owned::describe_topic_partitions_request::DescribeTopicPartitionsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeTopicPartitionsResponse" => {
let msg = krabka_protocol::owned::describe_topic_partitions_response::DescribeTopicPartitionsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_10(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"DescribeTransactionsRequest" => {
let msg = krabka_protocol::owned::describe_transactions_request::DescribeTransactionsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeTransactionsResponse" => {
let msg = krabka_protocol::owned::describe_transactions_response::DescribeTransactionsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeUserScramCredentialsRequest" => {
let msg = krabka_protocol::owned::describe_user_scram_credentials_request::DescribeUserScramCredentialsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeUserScramCredentialsResponse" => {
let msg = krabka_protocol::owned::describe_user_scram_credentials_response::DescribeUserScramCredentialsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ElectLeadersRequest" => {
let msg = krabka_protocol::owned::elect_leaders_request::ElectLeadersRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ElectLeadersResponse" => {
let msg =
krabka_protocol::owned::elect_leaders_response::ElectLeadersResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EndQuorumEpochRequest" => {
let msg =
krabka_protocol::owned::end_quorum_epoch_request::EndQuorumEpochRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EndQuorumEpochResponse" => {
let msg =
krabka_protocol::owned::end_quorum_epoch_response::EndQuorumEpochResponse::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_11(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"EndTxnRequest" => {
let msg = krabka_protocol::owned::end_txn_request::EndTxnRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EndTxnResponse" => {
let msg = krabka_protocol::owned::end_txn_response::EndTxnResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EnvelopeRequest" => {
let msg = krabka_protocol::owned::envelope_request::EnvelopeRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EnvelopeResponse" => {
let msg = krabka_protocol::owned::envelope_response::EnvelopeResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ExpireDelegationTokenRequest" => {
let msg = krabka_protocol::owned::expire_delegation_token_request::ExpireDelegationTokenRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ExpireDelegationTokenResponse" => {
let msg = krabka_protocol::owned::expire_delegation_token_response::ExpireDelegationTokenResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FetchRequest" => {
let msg = krabka_protocol::owned::fetch_request::FetchRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FetchResponse" => {
let msg = krabka_protocol::owned::fetch_response::FetchResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_12(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"FetchSnapshotRequest" => {
let msg =
krabka_protocol::owned::fetch_snapshot_request::FetchSnapshotRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FetchSnapshotResponse" => {
let msg =
krabka_protocol::owned::fetch_snapshot_response::FetchSnapshotResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FindCoordinatorRequest" => {
let msg =
krabka_protocol::owned::find_coordinator_request::FindCoordinatorRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FindCoordinatorResponse" => {
let msg =
krabka_protocol::owned::find_coordinator_response::FindCoordinatorResponse::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"GetTelemetrySubscriptionsRequest" => {
let msg = krabka_protocol::owned::get_telemetry_subscriptions_request::GetTelemetrySubscriptionsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"GetTelemetrySubscriptionsResponse" => {
let msg = krabka_protocol::owned::get_telemetry_subscriptions_response::GetTelemetrySubscriptionsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"HeartbeatRequest" => {
let msg = krabka_protocol::owned::heartbeat_request::HeartbeatRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"HeartbeatResponse" => {
let msg = krabka_protocol::owned::heartbeat_response::HeartbeatResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_13(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"IncrementalAlterConfigsRequest" => {
let msg = krabka_protocol::owned::incremental_alter_configs_request::IncrementalAlterConfigsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"IncrementalAlterConfigsResponse" => {
let msg = krabka_protocol::owned::incremental_alter_configs_response::IncrementalAlterConfigsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"InitProducerIdRequest" => {
let msg =
krabka_protocol::owned::init_producer_id_request::InitProducerIdRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"InitProducerIdResponse" => {
let msg =
krabka_protocol::owned::init_producer_id_response::InitProducerIdResponse::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"InitializeShareGroupStateRequest" => {
let msg = krabka_protocol::owned::initialize_share_group_state_request::InitializeShareGroupStateRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"InitializeShareGroupStateResponse" => {
let msg = krabka_protocol::owned::initialize_share_group_state_response::InitializeShareGroupStateResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"JoinGroupRequest" => {
let msg = krabka_protocol::owned::join_group_request::JoinGroupRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"JoinGroupResponse" => {
let msg = krabka_protocol::owned::join_group_response::JoinGroupResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_14(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"LeaveGroupRequest" => {
let msg = krabka_protocol::owned::leave_group_request::LeaveGroupRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"LeaveGroupResponse" => {
let msg = krabka_protocol::owned::leave_group_response::LeaveGroupResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListConfigResourcesRequest" => {
let msg = krabka_protocol::owned::list_config_resources_request::ListConfigResourcesRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListConfigResourcesResponse" => {
let msg = krabka_protocol::owned::list_config_resources_response::ListConfigResourcesResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListGroupsRequest" => {
let msg = krabka_protocol::owned::list_groups_request::ListGroupsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListGroupsResponse" => {
let msg = krabka_protocol::owned::list_groups_response::ListGroupsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListOffsetsRequest" => {
let msg = krabka_protocol::owned::list_offsets_request::ListOffsetsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListOffsetsResponse" => {
let msg = krabka_protocol::owned::list_offsets_response::ListOffsetsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_15(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"ListPartitionReassignmentsRequest" => {
let msg = krabka_protocol::owned::list_partition_reassignments_request::ListPartitionReassignmentsRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListPartitionReassignmentsResponse" => {
let msg = krabka_protocol::owned::list_partition_reassignments_response::ListPartitionReassignmentsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListTransactionsRequest" => {
let msg =
krabka_protocol::owned::list_transactions_request::ListTransactionsRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListTransactionsResponse" => {
let msg = krabka_protocol::owned::list_transactions_response::ListTransactionsResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"MetadataRequest" => {
let msg = krabka_protocol::owned::metadata_request::MetadataRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"MetadataResponse" => {
let msg = krabka_protocol::owned::metadata_response::MetadataResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetCommitRequest" => {
let msg = krabka_protocol::owned::offset_commit_request::OffsetCommitRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetCommitResponse" => {
let msg =
krabka_protocol::owned::offset_commit_response::OffsetCommitResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_16(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"OffsetDeleteRequest" => {
let msg = krabka_protocol::owned::offset_delete_request::OffsetDeleteRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetDeleteResponse" => {
let msg =
krabka_protocol::owned::offset_delete_response::OffsetDeleteResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetFetchRequest" => {
let msg = krabka_protocol::owned::offset_fetch_request::OffsetFetchRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetFetchResponse" => {
let msg = krabka_protocol::owned::offset_fetch_response::OffsetFetchResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetForLeaderEpochRequest" => {
let msg = krabka_protocol::owned::offset_for_leader_epoch_request::OffsetForLeaderEpochRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetForLeaderEpochResponse" => {
let msg = krabka_protocol::owned::offset_for_leader_epoch_response::OffsetForLeaderEpochResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ProduceRequest" => {
let msg = krabka_protocol::owned::produce_request::ProduceRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ProduceResponse" => {
let msg = krabka_protocol::owned::produce_response::ProduceResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_17(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"PushTelemetryRequest" => {
let msg =
krabka_protocol::owned::push_telemetry_request::PushTelemetryRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"PushTelemetryResponse" => {
let msg =
krabka_protocol::owned::push_telemetry_response::PushTelemetryResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ReadShareGroupStateRequest" => {
let msg = krabka_protocol::owned::read_share_group_state_request::ReadShareGroupStateRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ReadShareGroupStateResponse" => {
let msg = krabka_protocol::owned::read_share_group_state_response::ReadShareGroupStateResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ReadShareGroupStateSummaryRequest" => {
let msg = krabka_protocol::owned::read_share_group_state_summary_request::ReadShareGroupStateSummaryRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ReadShareGroupStateSummaryResponse" => {
let msg = krabka_protocol::owned::read_share_group_state_summary_response::ReadShareGroupStateSummaryResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"RemoveRaftVoterRequest" => {
let msg =
krabka_protocol::owned::remove_raft_voter_request::RemoveRaftVoterRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"RemoveRaftVoterResponse" => {
let msg = krabka_protocol::owned::remove_raft_voter_response::RemoveRaftVoterResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_18(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"RenewDelegationTokenRequest" => {
let msg = krabka_protocol::owned::renew_delegation_token_request::RenewDelegationTokenRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"RenewDelegationTokenResponse" => {
let msg = krabka_protocol::owned::renew_delegation_token_response::RenewDelegationTokenResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"RequestHeader" => {
let msg = krabka_protocol::owned::request_header::RequestHeader::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ResponseHeader" => {
let msg = krabka_protocol::owned::response_header::ResponseHeader::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SaslAuthenticateRequest" => {
let msg =
krabka_protocol::owned::sasl_authenticate_request::SaslAuthenticateRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SaslAuthenticateResponse" => {
let msg = krabka_protocol::owned::sasl_authenticate_response::SaslAuthenticateResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SaslHandshakeRequest" => {
let msg =
krabka_protocol::owned::sasl_handshake_request::SaslHandshakeRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SaslHandshakeResponse" => {
let msg =
krabka_protocol::owned::sasl_handshake_response::SaslHandshakeResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_19(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"ShareAcknowledgeRequest" => {
let msg =
krabka_protocol::owned::share_acknowledge_request::ShareAcknowledgeRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareAcknowledgeResponse" => {
let msg = krabka_protocol::owned::share_acknowledge_response::ShareAcknowledgeResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareFetchRequest" => {
let msg = krabka_protocol::owned::share_fetch_request::ShareFetchRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareFetchResponse" => {
let msg = krabka_protocol::owned::share_fetch_response::ShareFetchResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareGroupDescribeRequest" => {
let msg = krabka_protocol::owned::share_group_describe_request::ShareGroupDescribeRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareGroupDescribeResponse" => {
let msg = krabka_protocol::owned::share_group_describe_response::ShareGroupDescribeResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareGroupHeartbeatRequest" => {
let msg = krabka_protocol::owned::share_group_heartbeat_request::ShareGroupHeartbeatRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareGroupHeartbeatResponse" => {
let msg = krabka_protocol::owned::share_group_heartbeat_response::ShareGroupHeartbeatResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_20(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"StreamsGroupDescribeRequest" => {
let msg = krabka_protocol::owned::streams_group_describe_request::StreamsGroupDescribeRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupDescribeResponse" => {
let msg = krabka_protocol::owned::streams_group_describe_response::StreamsGroupDescribeResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupHeartbeatRequest" => {
let msg = krabka_protocol::owned::streams_group_heartbeat_request::StreamsGroupHeartbeatRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupHeartbeatResponse" => {
let msg = krabka_protocol::owned::streams_group_heartbeat_response::StreamsGroupHeartbeatResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupTopologyDescriptionUpdateRequest" => {
let msg = krabka_protocol::owned::streams_group_topology_description_update_request::StreamsGroupTopologyDescriptionUpdateRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupTopologyDescriptionUpdateResponse" => {
let msg = krabka_protocol::owned::streams_group_topology_description_update_response::StreamsGroupTopologyDescriptionUpdateResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SyncGroupRequest" => {
let msg = krabka_protocol::owned::sync_group_request::SyncGroupRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SyncGroupResponse" => {
let msg = krabka_protocol::owned::sync_group_response::SyncGroupResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_21(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"TxnOffsetCommitRequest" => {
let msg =
krabka_protocol::owned::txn_offset_commit_request::TxnOffsetCommitRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"TxnOffsetCommitResponse" => {
let msg = krabka_protocol::owned::txn_offset_commit_response::TxnOffsetCommitResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UnregisterBrokerRequest" => {
let msg =
krabka_protocol::owned::unregister_broker_request::UnregisterBrokerRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UnregisterBrokerResponse" => {
let msg = krabka_protocol::owned::unregister_broker_response::UnregisterBrokerResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UnregisterControllerRequest" => {
let msg = krabka_protocol::owned::unregister_controller_request::UnregisterControllerRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UnregisterControllerResponse" => {
let msg = krabka_protocol::owned::unregister_controller_response::UnregisterControllerResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UpdateFeaturesRequest" => {
let msg =
krabka_protocol::owned::update_features_request::UpdateFeaturesRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UpdateFeaturesResponse" => {
let msg =
krabka_protocol::owned::update_features_response::UpdateFeaturesResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn encode_default_22(name: &str, version: i16) -> Option<Vec<u8>> {
Some(match name {
"UpdateRaftVoterRequest" => {
let msg =
krabka_protocol::owned::update_raft_voter_request::UpdateRaftVoterRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UpdateRaftVoterResponse" => {
let msg = krabka_protocol::owned::update_raft_voter_response::UpdateRaftVoterResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"VoteRequest" => {
let msg = krabka_protocol::owned::vote_request::VoteRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"VoteResponse" => {
let msg = krabka_protocol::owned::vote_response::VoteResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"WriteShareGroupStateRequest" => {
let msg = krabka_protocol::owned::write_share_group_state_request::WriteShareGroupStateRequest::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"WriteShareGroupStateResponse" => {
let msg = krabka_protocol::owned::write_share_group_state_response::WriteShareGroupStateResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"WriteTxnMarkersRequest" => {
let msg =
krabka_protocol::owned::write_txn_markers_request::WriteTxnMarkersRequest::default(
);
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"WriteTxnMarkersResponse" => {
let msg = krabka_protocol::owned::write_txn_markers_response::WriteTxnMarkersResponse::default();
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
#[must_use]
pub fn encode_default(name: &str, version: i16) -> Vec<u8> {
let mut result = None;
result = result.or_else(|| encode_default_0(name, version));
result = result.or_else(|| encode_default_1(name, version));
result = result.or_else(|| encode_default_2(name, version));
result = result.or_else(|| encode_default_3(name, version));
result = result.or_else(|| encode_default_4(name, version));
result = result.or_else(|| encode_default_5(name, version));
result = result.or_else(|| encode_default_6(name, version));
result = result.or_else(|| encode_default_7(name, version));
result = result.or_else(|| encode_default_8(name, version));
result = result.or_else(|| encode_default_9(name, version));
result = result.or_else(|| encode_default_10(name, version));
result = result.or_else(|| encode_default_11(name, version));
result = result.or_else(|| encode_default_12(name, version));
result = result.or_else(|| encode_default_13(name, version));
result = result.or_else(|| encode_default_14(name, version));
result = result.or_else(|| encode_default_15(name, version));
result = result.or_else(|| encode_default_16(name, version));
result = result.or_else(|| encode_default_17(name, version));
result = result.or_else(|| encode_default_18(name, version));
result = result.or_else(|| encode_default_19(name, version));
result = result.or_else(|| encode_default_20(name, version));
result = result.or_else(|| encode_default_21(name, version));
result = result.or_else(|| encode_default_22(name, version));
result.unwrap_or_else(|| panic!("unknown message in encode_default: {name}"))
}
fn default_json_for_0(name: &str, version: i16) -> Option<::serde_json::Value> {
Some(match name {
"AddOffsetsToTxnRequest" => {
krabka_protocol::owned::add_offsets_to_txn_request::default_json(version)
}
"AddOffsetsToTxnResponse" => {
krabka_protocol::owned::add_offsets_to_txn_response::default_json(version)
}
"AddPartitionsToTxnRequest" => {
krabka_protocol::owned::add_partitions_to_txn_request::default_json(version)
}
"AddPartitionsToTxnResponse" => {
krabka_protocol::owned::add_partitions_to_txn_response::default_json(version)
}
"AddRaftVoterRequest" => {
krabka_protocol::owned::add_raft_voter_request::default_json(version)
}
"AddRaftVoterResponse" => {
krabka_protocol::owned::add_raft_voter_response::default_json(version)
}
"AllocateProducerIdsRequest" => {
krabka_protocol::owned::allocate_producer_ids_request::default_json(version)
}
"AllocateProducerIdsResponse" => {
krabka_protocol::owned::allocate_producer_ids_response::default_json(version)
}
"AlterClientQuotasRequest" => {
krabka_protocol::owned::alter_client_quotas_request::default_json(version)
}
"AlterClientQuotasResponse" => {
krabka_protocol::owned::alter_client_quotas_response::default_json(version)
}
"AlterConfigsRequest" => {
krabka_protocol::owned::alter_configs_request::default_json(version)
}
"AlterConfigsResponse" => {
krabka_protocol::owned::alter_configs_response::default_json(version)
}
"AlterPartitionReassignmentsRequest" => {
krabka_protocol::owned::alter_partition_reassignments_request::default_json(version)
}
"AlterPartitionReassignmentsResponse" => {
krabka_protocol::owned::alter_partition_reassignments_response::default_json(version)
}
"AlterPartitionRequest" => {
krabka_protocol::owned::alter_partition_request::default_json(version)
}
"AlterPartitionResponse" => {
krabka_protocol::owned::alter_partition_response::default_json(version)
}
"AlterReplicaLogDirsRequest" => {
krabka_protocol::owned::alter_replica_log_dirs_request::default_json(version)
}
"AlterReplicaLogDirsResponse" => {
krabka_protocol::owned::alter_replica_log_dirs_response::default_json(version)
}
"AlterShareGroupOffsetsRequest" => {
krabka_protocol::owned::alter_share_group_offsets_request::default_json(version)
}
"AlterShareGroupOffsetsResponse" => {
krabka_protocol::owned::alter_share_group_offsets_response::default_json(version)
}
"AlterUserScramCredentialsRequest" => {
krabka_protocol::owned::alter_user_scram_credentials_request::default_json(version)
}
"AlterUserScramCredentialsResponse" => {
krabka_protocol::owned::alter_user_scram_credentials_response::default_json(version)
}
"ApiVersionsRequest" => krabka_protocol::owned::api_versions_request::default_json(version),
"ApiVersionsResponse" => {
krabka_protocol::owned::api_versions_response::default_json(version)
}
"AssignReplicasToDirsRequest" => {
krabka_protocol::owned::assign_replicas_to_dirs_request::default_json(version)
}
"AssignReplicasToDirsResponse" => {
krabka_protocol::owned::assign_replicas_to_dirs_response::default_json(version)
}
"BeginQuorumEpochRequest" => {
krabka_protocol::owned::begin_quorum_epoch_request::default_json(version)
}
"BeginQuorumEpochResponse" => {
krabka_protocol::owned::begin_quorum_epoch_response::default_json(version)
}
"BrokerHeartbeatRequest" => {
krabka_protocol::owned::broker_heartbeat_request::default_json(version)
}
"BrokerHeartbeatResponse" => {
krabka_protocol::owned::broker_heartbeat_response::default_json(version)
}
"BrokerRegistrationRequest" => {
krabka_protocol::owned::broker_registration_request::default_json(version)
}
"BrokerRegistrationResponse" => {
krabka_protocol::owned::broker_registration_response::default_json(version)
}
"ConsumerGroupDescribeRequest" => {
krabka_protocol::owned::consumer_group_describe_request::default_json(version)
}
"ConsumerGroupDescribeResponse" => {
krabka_protocol::owned::consumer_group_describe_response::default_json(version)
}
"ConsumerGroupHeartbeatRequest" => {
krabka_protocol::owned::consumer_group_heartbeat_request::default_json(version)
}
"ConsumerGroupHeartbeatResponse" => {
krabka_protocol::owned::consumer_group_heartbeat_response::default_json(version)
}
"ControllerRegistrationRequest" => {
krabka_protocol::owned::controller_registration_request::default_json(version)
}
"ControllerRegistrationResponse" => {
krabka_protocol::owned::controller_registration_response::default_json(version)
}
"CreateAclsRequest" => krabka_protocol::owned::create_acls_request::default_json(version),
"CreateAclsResponse" => krabka_protocol::owned::create_acls_response::default_json(version),
"CreateDelegationTokenRequest" => {
krabka_protocol::owned::create_delegation_token_request::default_json(version)
}
"CreateDelegationTokenResponse" => {
krabka_protocol::owned::create_delegation_token_response::default_json(version)
}
"CreatePartitionsRequest" => {
krabka_protocol::owned::create_partitions_request::default_json(version)
}
"CreatePartitionsResponse" => {
krabka_protocol::owned::create_partitions_response::default_json(version)
}
"CreateTopicsRequest" => {
krabka_protocol::owned::create_topics_request::default_json(version)
}
"CreateTopicsResponse" => {
krabka_protocol::owned::create_topics_response::default_json(version)
}
"DeleteAclsRequest" => krabka_protocol::owned::delete_acls_request::default_json(version),
"DeleteAclsResponse" => krabka_protocol::owned::delete_acls_response::default_json(version),
"DeleteGroupsRequest" => {
krabka_protocol::owned::delete_groups_request::default_json(version)
}
"DeleteGroupsResponse" => {
krabka_protocol::owned::delete_groups_response::default_json(version)
}
"DeleteRecordsRequest" => {
krabka_protocol::owned::delete_records_request::default_json(version)
}
"DeleteRecordsResponse" => {
krabka_protocol::owned::delete_records_response::default_json(version)
}
"DeleteShareGroupOffsetsRequest" => {
krabka_protocol::owned::delete_share_group_offsets_request::default_json(version)
}
"DeleteShareGroupOffsetsResponse" => {
krabka_protocol::owned::delete_share_group_offsets_response::default_json(version)
}
"DeleteShareGroupStateRequest" => {
krabka_protocol::owned::delete_share_group_state_request::default_json(version)
}
"DeleteShareGroupStateResponse" => {
krabka_protocol::owned::delete_share_group_state_response::default_json(version)
}
"DeleteTopicsRequest" => {
krabka_protocol::owned::delete_topics_request::default_json(version)
}
"DeleteTopicsResponse" => {
krabka_protocol::owned::delete_topics_response::default_json(version)
}
"DescribeAclsRequest" => {
krabka_protocol::owned::describe_acls_request::default_json(version)
}
"DescribeAclsResponse" => {
krabka_protocol::owned::describe_acls_response::default_json(version)
}
_ => return None,
})
}
fn default_json_for_1(name: &str, version: i16) -> Option<::serde_json::Value> {
Some(match name {
"DescribeClientQuotasRequest" => {
krabka_protocol::owned::describe_client_quotas_request::default_json(version)
}
"DescribeClientQuotasResponse" => {
krabka_protocol::owned::describe_client_quotas_response::default_json(version)
}
"DescribeClusterRequest" => {
krabka_protocol::owned::describe_cluster_request::default_json(version)
}
"DescribeClusterResponse" => {
krabka_protocol::owned::describe_cluster_response::default_json(version)
}
"DescribeConfigsRequest" => {
krabka_protocol::owned::describe_configs_request::default_json(version)
}
"DescribeConfigsResponse" => {
krabka_protocol::owned::describe_configs_response::default_json(version)
}
"DescribeDelegationTokenRequest" => {
krabka_protocol::owned::describe_delegation_token_request::default_json(version)
}
"DescribeDelegationTokenResponse" => {
krabka_protocol::owned::describe_delegation_token_response::default_json(version)
}
"DescribeGroupsRequest" => {
krabka_protocol::owned::describe_groups_request::default_json(version)
}
"DescribeGroupsResponse" => {
krabka_protocol::owned::describe_groups_response::default_json(version)
}
"DescribeLogDirsRequest" => {
krabka_protocol::owned::describe_log_dirs_request::default_json(version)
}
"DescribeLogDirsResponse" => {
krabka_protocol::owned::describe_log_dirs_response::default_json(version)
}
"DescribeProducersRequest" => {
krabka_protocol::owned::describe_producers_request::default_json(version)
}
"DescribeProducersResponse" => {
krabka_protocol::owned::describe_producers_response::default_json(version)
}
"DescribeQuorumRequest" => {
krabka_protocol::owned::describe_quorum_request::default_json(version)
}
"DescribeQuorumResponse" => {
krabka_protocol::owned::describe_quorum_response::default_json(version)
}
"DescribeShareGroupOffsetsRequest" => {
krabka_protocol::owned::describe_share_group_offsets_request::default_json(version)
}
"DescribeShareGroupOffsetsResponse" => {
krabka_protocol::owned::describe_share_group_offsets_response::default_json(version)
}
"DescribeTopicPartitionsRequest" => {
krabka_protocol::owned::describe_topic_partitions_request::default_json(version)
}
"DescribeTopicPartitionsResponse" => {
krabka_protocol::owned::describe_topic_partitions_response::default_json(version)
}
"DescribeTransactionsRequest" => {
krabka_protocol::owned::describe_transactions_request::default_json(version)
}
"DescribeTransactionsResponse" => {
krabka_protocol::owned::describe_transactions_response::default_json(version)
}
"DescribeUserScramCredentialsRequest" => {
krabka_protocol::owned::describe_user_scram_credentials_request::default_json(version)
}
"DescribeUserScramCredentialsResponse" => {
krabka_protocol::owned::describe_user_scram_credentials_response::default_json(version)
}
"ElectLeadersRequest" => {
krabka_protocol::owned::elect_leaders_request::default_json(version)
}
"ElectLeadersResponse" => {
krabka_protocol::owned::elect_leaders_response::default_json(version)
}
"EndQuorumEpochRequest" => {
krabka_protocol::owned::end_quorum_epoch_request::default_json(version)
}
"EndQuorumEpochResponse" => {
krabka_protocol::owned::end_quorum_epoch_response::default_json(version)
}
"EndTxnRequest" => krabka_protocol::owned::end_txn_request::default_json(version),
"EndTxnResponse" => krabka_protocol::owned::end_txn_response::default_json(version),
"EnvelopeRequest" => krabka_protocol::owned::envelope_request::default_json(version),
"EnvelopeResponse" => krabka_protocol::owned::envelope_response::default_json(version),
"ExpireDelegationTokenRequest" => {
krabka_protocol::owned::expire_delegation_token_request::default_json(version)
}
"ExpireDelegationTokenResponse" => {
krabka_protocol::owned::expire_delegation_token_response::default_json(version)
}
"FetchRequest" => krabka_protocol::owned::fetch_request::default_json(version),
"FetchResponse" => krabka_protocol::owned::fetch_response::default_json(version),
"FetchSnapshotRequest" => {
krabka_protocol::owned::fetch_snapshot_request::default_json(version)
}
"FetchSnapshotResponse" => {
krabka_protocol::owned::fetch_snapshot_response::default_json(version)
}
"FindCoordinatorRequest" => {
krabka_protocol::owned::find_coordinator_request::default_json(version)
}
"FindCoordinatorResponse" => {
krabka_protocol::owned::find_coordinator_response::default_json(version)
}
"GetTelemetrySubscriptionsRequest" => {
krabka_protocol::owned::get_telemetry_subscriptions_request::default_json(version)
}
"GetTelemetrySubscriptionsResponse" => {
krabka_protocol::owned::get_telemetry_subscriptions_response::default_json(version)
}
"HeartbeatRequest" => krabka_protocol::owned::heartbeat_request::default_json(version),
"HeartbeatResponse" => krabka_protocol::owned::heartbeat_response::default_json(version),
"IncrementalAlterConfigsRequest" => {
krabka_protocol::owned::incremental_alter_configs_request::default_json(version)
}
"IncrementalAlterConfigsResponse" => {
krabka_protocol::owned::incremental_alter_configs_response::default_json(version)
}
"InitProducerIdRequest" => {
krabka_protocol::owned::init_producer_id_request::default_json(version)
}
"InitProducerIdResponse" => {
krabka_protocol::owned::init_producer_id_response::default_json(version)
}
"InitializeShareGroupStateRequest" => {
krabka_protocol::owned::initialize_share_group_state_request::default_json(version)
}
"InitializeShareGroupStateResponse" => {
krabka_protocol::owned::initialize_share_group_state_response::default_json(version)
}
"JoinGroupRequest" => krabka_protocol::owned::join_group_request::default_json(version),
"JoinGroupResponse" => krabka_protocol::owned::join_group_response::default_json(version),
"LeaveGroupRequest" => krabka_protocol::owned::leave_group_request::default_json(version),
"LeaveGroupResponse" => krabka_protocol::owned::leave_group_response::default_json(version),
"ListConfigResourcesRequest" => {
krabka_protocol::owned::list_config_resources_request::default_json(version)
}
"ListConfigResourcesResponse" => {
krabka_protocol::owned::list_config_resources_response::default_json(version)
}
"ListGroupsRequest" => krabka_protocol::owned::list_groups_request::default_json(version),
"ListGroupsResponse" => krabka_protocol::owned::list_groups_response::default_json(version),
"ListOffsetsRequest" => krabka_protocol::owned::list_offsets_request::default_json(version),
"ListOffsetsResponse" => {
krabka_protocol::owned::list_offsets_response::default_json(version)
}
_ => return None,
})
}
fn default_json_for_2(name: &str, version: i16) -> Option<::serde_json::Value> {
Some(match name {
"ListPartitionReassignmentsRequest" => {
krabka_protocol::owned::list_partition_reassignments_request::default_json(version)
}
"ListPartitionReassignmentsResponse" => {
krabka_protocol::owned::list_partition_reassignments_response::default_json(version)
}
"ListTransactionsRequest" => {
krabka_protocol::owned::list_transactions_request::default_json(version)
}
"ListTransactionsResponse" => {
krabka_protocol::owned::list_transactions_response::default_json(version)
}
"MetadataRequest" => krabka_protocol::owned::metadata_request::default_json(version),
"MetadataResponse" => krabka_protocol::owned::metadata_response::default_json(version),
"OffsetCommitRequest" => {
krabka_protocol::owned::offset_commit_request::default_json(version)
}
"OffsetCommitResponse" => {
krabka_protocol::owned::offset_commit_response::default_json(version)
}
"OffsetDeleteRequest" => {
krabka_protocol::owned::offset_delete_request::default_json(version)
}
"OffsetDeleteResponse" => {
krabka_protocol::owned::offset_delete_response::default_json(version)
}
"OffsetFetchRequest" => krabka_protocol::owned::offset_fetch_request::default_json(version),
"OffsetFetchResponse" => {
krabka_protocol::owned::offset_fetch_response::default_json(version)
}
"OffsetForLeaderEpochRequest" => {
krabka_protocol::owned::offset_for_leader_epoch_request::default_json(version)
}
"OffsetForLeaderEpochResponse" => {
krabka_protocol::owned::offset_for_leader_epoch_response::default_json(version)
}
"ProduceRequest" => krabka_protocol::owned::produce_request::default_json(version),
"ProduceResponse" => krabka_protocol::owned::produce_response::default_json(version),
"PushTelemetryRequest" => {
krabka_protocol::owned::push_telemetry_request::default_json(version)
}
"PushTelemetryResponse" => {
krabka_protocol::owned::push_telemetry_response::default_json(version)
}
"ReadShareGroupStateRequest" => {
krabka_protocol::owned::read_share_group_state_request::default_json(version)
}
"ReadShareGroupStateResponse" => {
krabka_protocol::owned::read_share_group_state_response::default_json(version)
}
"ReadShareGroupStateSummaryRequest" => {
krabka_protocol::owned::read_share_group_state_summary_request::default_json(version)
}
"ReadShareGroupStateSummaryResponse" => {
krabka_protocol::owned::read_share_group_state_summary_response::default_json(version)
}
"RemoveRaftVoterRequest" => {
krabka_protocol::owned::remove_raft_voter_request::default_json(version)
}
"RemoveRaftVoterResponse" => {
krabka_protocol::owned::remove_raft_voter_response::default_json(version)
}
"RenewDelegationTokenRequest" => {
krabka_protocol::owned::renew_delegation_token_request::default_json(version)
}
"RenewDelegationTokenResponse" => {
krabka_protocol::owned::renew_delegation_token_response::default_json(version)
}
"RequestHeader" => krabka_protocol::owned::request_header::default_json(version),
"ResponseHeader" => krabka_protocol::owned::response_header::default_json(version),
"SaslAuthenticateRequest" => {
krabka_protocol::owned::sasl_authenticate_request::default_json(version)
}
"SaslAuthenticateResponse" => {
krabka_protocol::owned::sasl_authenticate_response::default_json(version)
}
"SaslHandshakeRequest" => {
krabka_protocol::owned::sasl_handshake_request::default_json(version)
}
"SaslHandshakeResponse" => {
krabka_protocol::owned::sasl_handshake_response::default_json(version)
}
"ShareAcknowledgeRequest" => {
krabka_protocol::owned::share_acknowledge_request::default_json(version)
}
"ShareAcknowledgeResponse" => {
krabka_protocol::owned::share_acknowledge_response::default_json(version)
}
"ShareFetchRequest" => krabka_protocol::owned::share_fetch_request::default_json(version),
"ShareFetchResponse" => krabka_protocol::owned::share_fetch_response::default_json(version),
"ShareGroupDescribeRequest" => {
krabka_protocol::owned::share_group_describe_request::default_json(version)
}
"ShareGroupDescribeResponse" => {
krabka_protocol::owned::share_group_describe_response::default_json(version)
}
"ShareGroupHeartbeatRequest" => {
krabka_protocol::owned::share_group_heartbeat_request::default_json(version)
}
"ShareGroupHeartbeatResponse" => {
krabka_protocol::owned::share_group_heartbeat_response::default_json(version)
}
"StreamsGroupDescribeRequest" => {
krabka_protocol::owned::streams_group_describe_request::default_json(version)
}
"StreamsGroupDescribeResponse" => {
krabka_protocol::owned::streams_group_describe_response::default_json(version)
}
"StreamsGroupHeartbeatRequest" => {
krabka_protocol::owned::streams_group_heartbeat_request::default_json(version)
}
"StreamsGroupHeartbeatResponse" => {
krabka_protocol::owned::streams_group_heartbeat_response::default_json(version)
}
"StreamsGroupTopologyDescriptionUpdateRequest" => {
krabka_protocol::owned::streams_group_topology_description_update_request::default_json(
version,
)
}
"StreamsGroupTopologyDescriptionUpdateResponse" => {
krabka_protocol::owned::streams_group_topology_description_update_response::default_json(
version,
)
}
"SyncGroupRequest" => krabka_protocol::owned::sync_group_request::default_json(version),
"SyncGroupResponse" => krabka_protocol::owned::sync_group_response::default_json(version),
"TxnOffsetCommitRequest" => {
krabka_protocol::owned::txn_offset_commit_request::default_json(version)
}
"TxnOffsetCommitResponse" => {
krabka_protocol::owned::txn_offset_commit_response::default_json(version)
}
"UnregisterBrokerRequest" => {
krabka_protocol::owned::unregister_broker_request::default_json(version)
}
"UnregisterBrokerResponse" => {
krabka_protocol::owned::unregister_broker_response::default_json(version)
}
"UnregisterControllerRequest" => {
krabka_protocol::owned::unregister_controller_request::default_json(version)
}
"UnregisterControllerResponse" => {
krabka_protocol::owned::unregister_controller_response::default_json(version)
}
"UpdateFeaturesRequest" => {
krabka_protocol::owned::update_features_request::default_json(version)
}
"UpdateFeaturesResponse" => {
krabka_protocol::owned::update_features_response::default_json(version)
}
"UpdateRaftVoterRequest" => {
krabka_protocol::owned::update_raft_voter_request::default_json(version)
}
"UpdateRaftVoterResponse" => {
krabka_protocol::owned::update_raft_voter_response::default_json(version)
}
"VoteRequest" => krabka_protocol::owned::vote_request::default_json(version),
"VoteResponse" => krabka_protocol::owned::vote_response::default_json(version),
_ => return None,
})
}
fn default_json_for_3(name: &str, version: i16) -> Option<::serde_json::Value> {
Some(match name {
"WriteShareGroupStateRequest" => {
krabka_protocol::owned::write_share_group_state_request::default_json(version)
}
"WriteShareGroupStateResponse" => {
krabka_protocol::owned::write_share_group_state_response::default_json(version)
}
"WriteTxnMarkersRequest" => {
krabka_protocol::owned::write_txn_markers_request::default_json(version)
}
"WriteTxnMarkersResponse" => {
krabka_protocol::owned::write_txn_markers_response::default_json(version)
}
_ => return None,
})
}
#[must_use]
pub fn default_json_for(name: &str, version: i16) -> ::serde_json::Value {
let mut result = None;
result = result.or_else(|| default_json_for_0(name, version));
result = result.or_else(|| default_json_for_1(name, version));
result = result.or_else(|| default_json_for_2(name, version));
result = result.or_else(|| default_json_for_3(name, version));
result.unwrap_or_else(|| panic!("unknown message in default_json_for: {name}"))
}
#[derive(Debug, Clone, Copy)]
pub struct TaggedCase {
pub name: &'static str,
pub version: i16,
}
pub const TAGGED_CASES: &[TaggedCase] = &[
TaggedCase {
name: "ApiVersionsResponse",
version: 0,
},
TaggedCase {
name: "ApiVersionsResponse",
version: 1,
},
TaggedCase {
name: "ApiVersionsResponse",
version: 2,
},
TaggedCase {
name: "ApiVersionsResponse",
version: 3,
},
TaggedCase {
name: "ApiVersionsResponse",
version: 4,
},
TaggedCase {
name: "ApiVersionsResponse",
version: 5,
},
TaggedCase {
name: "BeginQuorumEpochResponse",
version: 0,
},
TaggedCase {
name: "BeginQuorumEpochResponse",
version: 1,
},
TaggedCase {
name: "BeginTransactionRecord",
version: 0,
},
TaggedCase {
name: "BrokerHeartbeatRequest",
version: 0,
},
TaggedCase {
name: "BrokerHeartbeatRequest",
version: 1,
},
TaggedCase {
name: "BrokerHeartbeatRequest",
version: 2,
},
TaggedCase {
name: "BrokerRegistrationChangeRecord",
version: 0,
},
TaggedCase {
name: "BrokerRegistrationChangeRecord",
version: 1,
},
TaggedCase {
name: "BrokerRegistrationChangeRecord",
version: 2,
},
TaggedCase {
name: "BrokerRegistrationChangeRecord",
version: 3,
},
TaggedCase {
name: "CreateTopicsResponse",
version: 2,
},
TaggedCase {
name: "CreateTopicsResponse",
version: 3,
},
TaggedCase {
name: "CreateTopicsResponse",
version: 4,
},
TaggedCase {
name: "CreateTopicsResponse",
version: 5,
},
TaggedCase {
name: "CreateTopicsResponse",
version: 6,
},
TaggedCase {
name: "CreateTopicsResponse",
version: 7,
},
TaggedCase {
name: "EndQuorumEpochResponse",
version: 0,
},
TaggedCase {
name: "EndQuorumEpochResponse",
version: 1,
},
TaggedCase {
name: "FetchRequest",
version: 4,
},
TaggedCase {
name: "FetchRequest",
version: 5,
},
TaggedCase {
name: "FetchRequest",
version: 6,
},
TaggedCase {
name: "FetchRequest",
version: 7,
},
TaggedCase {
name: "FetchRequest",
version: 8,
},
TaggedCase {
name: "FetchRequest",
version: 9,
},
TaggedCase {
name: "FetchRequest",
version: 10,
},
TaggedCase {
name: "FetchRequest",
version: 11,
},
TaggedCase {
name: "FetchRequest",
version: 12,
},
TaggedCase {
name: "FetchRequest",
version: 13,
},
TaggedCase {
name: "FetchRequest",
version: 14,
},
TaggedCase {
name: "FetchRequest",
version: 15,
},
TaggedCase {
name: "FetchRequest",
version: 16,
},
TaggedCase {
name: "FetchRequest",
version: 17,
},
TaggedCase {
name: "FetchRequest",
version: 18,
},
TaggedCase {
name: "FetchResponse",
version: 4,
},
TaggedCase {
name: "FetchResponse",
version: 5,
},
TaggedCase {
name: "FetchResponse",
version: 6,
},
TaggedCase {
name: "FetchResponse",
version: 7,
},
TaggedCase {
name: "FetchResponse",
version: 8,
},
TaggedCase {
name: "FetchResponse",
version: 9,
},
TaggedCase {
name: "FetchResponse",
version: 10,
},
TaggedCase {
name: "FetchResponse",
version: 11,
},
TaggedCase {
name: "FetchResponse",
version: 12,
},
TaggedCase {
name: "FetchResponse",
version: 13,
},
TaggedCase {
name: "FetchResponse",
version: 14,
},
TaggedCase {
name: "FetchResponse",
version: 15,
},
TaggedCase {
name: "FetchResponse",
version: 16,
},
TaggedCase {
name: "FetchResponse",
version: 17,
},
TaggedCase {
name: "FetchResponse",
version: 18,
},
TaggedCase {
name: "FetchSnapshotRequest",
version: 0,
},
TaggedCase {
name: "FetchSnapshotRequest",
version: 1,
},
TaggedCase {
name: "FetchSnapshotResponse",
version: 0,
},
TaggedCase {
name: "FetchSnapshotResponse",
version: 1,
},
TaggedCase {
name: "OffsetCommitValue",
version: 0,
},
TaggedCase {
name: "OffsetCommitValue",
version: 1,
},
TaggedCase {
name: "OffsetCommitValue",
version: 2,
},
TaggedCase {
name: "OffsetCommitValue",
version: 3,
},
TaggedCase {
name: "OffsetCommitValue",
version: 4,
},
TaggedCase {
name: "PartitionChangeRecord",
version: 0,
},
TaggedCase {
name: "PartitionChangeRecord",
version: 1,
},
TaggedCase {
name: "PartitionChangeRecord",
version: 2,
},
TaggedCase {
name: "PartitionRecord",
version: 0,
},
TaggedCase {
name: "PartitionRecord",
version: 1,
},
TaggedCase {
name: "PartitionRecord",
version: 2,
},
TaggedCase {
name: "ProduceResponse",
version: 3,
},
TaggedCase {
name: "ProduceResponse",
version: 4,
},
TaggedCase {
name: "ProduceResponse",
version: 5,
},
TaggedCase {
name: "ProduceResponse",
version: 6,
},
TaggedCase {
name: "ProduceResponse",
version: 7,
},
TaggedCase {
name: "ProduceResponse",
version: 8,
},
TaggedCase {
name: "ProduceResponse",
version: 9,
},
TaggedCase {
name: "ProduceResponse",
version: 10,
},
TaggedCase {
name: "ProduceResponse",
version: 11,
},
TaggedCase {
name: "ProduceResponse",
version: 12,
},
TaggedCase {
name: "ProduceResponse",
version: 13,
},
TaggedCase {
name: "RegisterBrokerRecord",
version: 0,
},
TaggedCase {
name: "RegisterBrokerRecord",
version: 1,
},
TaggedCase {
name: "RegisterBrokerRecord",
version: 2,
},
TaggedCase {
name: "RegisterBrokerRecord",
version: 3,
},
TaggedCase {
name: "RegisterBrokerRecord",
version: 4,
},
TaggedCase {
name: "RemoteLogSegmentMetadataRecord",
version: 0,
},
TaggedCase {
name: "RemoteLogSegmentMetadataSnapshotRecord",
version: 0,
},
TaggedCase {
name: "UpdateRaftVoterResponse",
version: 0,
},
TaggedCase {
name: "VoteResponse",
version: 0,
},
TaggedCase {
name: "VoteResponse",
version: 1,
},
TaggedCase {
name: "VoteResponse",
version: 2,
},
];
fn encode_with<T: Encode>(message: &T, version: i16) -> Vec<u8> {
let mut buf = BytesMut::new();
message.encode(&mut buf, version).unwrap();
buf.to_vec()
}
fn encode_tagged_fixture_0(name: &str, version: i16) -> Option<(Vec<u8>, Vec<u8>)> {
use krabka_protocol::DecodeBorrow;
Some(match name {
"ApiVersionsResponse" => {
let owned = krabka_protocol::owned::api_versions_response::tagged_fixture();
let max = krabka_protocol::owned::api_versions_response::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::api_versions_response::ApiVersionsResponse::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"BeginQuorumEpochResponse" => {
let owned = krabka_protocol::owned::begin_quorum_epoch_response::tagged_fixture();
let max = krabka_protocol::owned::begin_quorum_epoch_response::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::begin_quorum_epoch_response::BeginQuorumEpochResponse::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"BeginTransactionRecord" => {
let owned = krabka_protocol::owned::begin_transaction_record::tagged_fixture();
let max = krabka_protocol::owned::begin_transaction_record::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::begin_transaction_record::BeginTransactionRecord::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"BrokerHeartbeatRequest" => {
let owned = krabka_protocol::owned::broker_heartbeat_request::tagged_fixture();
let max = krabka_protocol::owned::broker_heartbeat_request::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::broker_heartbeat_request::BrokerHeartbeatRequest::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"BrokerRegistrationChangeRecord" => {
let owned = krabka_protocol::owned::broker_registration_change_record::tagged_fixture();
let max = krabka_protocol::owned::broker_registration_change_record::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::broker_registration_change_record::BrokerRegistrationChangeRecord::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"CreateTopicsResponse" => {
let owned = krabka_protocol::owned::create_topics_response::tagged_fixture();
let max = krabka_protocol::owned::create_topics_response::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::create_topics_response::CreateTopicsResponse::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
_ => return None,
})
}
fn encode_tagged_fixture_1(name: &str, version: i16) -> Option<(Vec<u8>, Vec<u8>)> {
use krabka_protocol::DecodeBorrow;
Some(match name {
"EndQuorumEpochResponse" => {
let owned = krabka_protocol::owned::end_quorum_epoch_response::tagged_fixture();
let max = krabka_protocol::owned::end_quorum_epoch_response::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::end_quorum_epoch_response::EndQuorumEpochResponse::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"FetchRequest" => {
let owned = krabka_protocol::owned::fetch_request::tagged_fixture();
let max = krabka_protocol::owned::fetch_request::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::fetch_request::FetchRequest::decode_borrow(
&mut cur, max,
)
.unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"FetchResponse" => {
let owned = krabka_protocol::owned::fetch_response::tagged_fixture();
let max = krabka_protocol::owned::fetch_response::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::fetch_response::FetchResponse::decode_borrow(
&mut cur, max,
)
.unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"FetchSnapshotRequest" => {
let owned = krabka_protocol::owned::fetch_snapshot_request::tagged_fixture();
let max = krabka_protocol::owned::fetch_snapshot_request::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::fetch_snapshot_request::FetchSnapshotRequest::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"FetchSnapshotResponse" => {
let owned = krabka_protocol::owned::fetch_snapshot_response::tagged_fixture();
let max = krabka_protocol::owned::fetch_snapshot_response::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::fetch_snapshot_response::FetchSnapshotResponse::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"OffsetCommitValue" => {
let owned = krabka_protocol::owned::offset_commit_value::tagged_fixture();
let max = krabka_protocol::owned::offset_commit_value::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed =
krabka_protocol::borrowed::offset_commit_value::OffsetCommitValue::decode_borrow(
&mut cur, max,
)
.unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
_ => return None,
})
}
fn encode_tagged_fixture_2(name: &str, version: i16) -> Option<(Vec<u8>, Vec<u8>)> {
use krabka_protocol::DecodeBorrow;
Some(match name {
"PartitionChangeRecord" => {
let owned = krabka_protocol::owned::partition_change_record::tagged_fixture();
let max = krabka_protocol::owned::partition_change_record::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::partition_change_record::PartitionChangeRecord::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"PartitionRecord" => {
let owned = krabka_protocol::owned::partition_record::tagged_fixture();
let max = krabka_protocol::owned::partition_record::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed =
krabka_protocol::borrowed::partition_record::PartitionRecord::decode_borrow(
&mut cur, max,
)
.unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"ProduceResponse" => {
let owned = krabka_protocol::owned::produce_response::tagged_fixture();
let max = krabka_protocol::owned::produce_response::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed =
krabka_protocol::borrowed::produce_response::ProduceResponse::decode_borrow(
&mut cur, max,
)
.unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"RegisterBrokerRecord" => {
let owned = krabka_protocol::owned::register_broker_record::tagged_fixture();
let max = krabka_protocol::owned::register_broker_record::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::register_broker_record::RegisterBrokerRecord::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"RemoteLogSegmentMetadataRecord" => {
let owned =
krabka_protocol::owned::remote_log_segment_metadata_record::tagged_fixture();
let max = krabka_protocol::owned::remote_log_segment_metadata_record::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::remote_log_segment_metadata_record::RemoteLogSegmentMetadataRecord::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"RemoteLogSegmentMetadataSnapshotRecord" => {
let owned =
krabka_protocol::owned::remote_log_segment_metadata_snapshot_record::tagged_fixture(
);
let max =
krabka_protocol::owned::remote_log_segment_metadata_snapshot_record::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::remote_log_segment_metadata_snapshot_record::RemoteLogSegmentMetadataSnapshotRecord::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
_ => return None,
})
}
fn encode_tagged_fixture_3(name: &str, version: i16) -> Option<(Vec<u8>, Vec<u8>)> {
use krabka_protocol::DecodeBorrow;
Some(match name {
"UpdateRaftVoterResponse" => {
let owned = krabka_protocol::owned::update_raft_voter_response::tagged_fixture();
let max = krabka_protocol::owned::update_raft_voter_response::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::update_raft_voter_response::UpdateRaftVoterResponse::decode_borrow(&mut cur, max).unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
"VoteResponse" => {
let owned = krabka_protocol::owned::vote_response::tagged_fixture();
let max = krabka_protocol::owned::vote_response::MAX_VERSION;
let full = encode_with(&owned, max);
let mut cur = full.as_slice();
let borrowed = krabka_protocol::borrowed::vote_response::VoteResponse::decode_borrow(
&mut cur, max,
)
.unwrap();
assert2::assert!(cur.is_empty());
(
encode_with(&owned, version),
encode_with(&borrowed, version),
)
}
_ => return None,
})
}
#[must_use]
pub fn encode_tagged_fixture(name: &str, version: i16) -> (Vec<u8>, Vec<u8>) {
let mut result = None;
result = result.or_else(|| encode_tagged_fixture_0(name, version));
result = result.or_else(|| encode_tagged_fixture_1(name, version));
result = result.or_else(|| encode_tagged_fixture_2(name, version));
result = result.or_else(|| encode_tagged_fixture_3(name, version));
result.unwrap_or_else(|| panic!("unknown message in encode_tagged_fixture: {name}"))
}
#[must_use]
pub fn tagged_fixture_json_for(name: &str, version: i16) -> ::serde_json::Value {
match name {
"ApiVersionsResponse" => {
krabka_protocol::owned::api_versions_response::tagged_fixture_json(version)
}
"BeginQuorumEpochResponse" => {
krabka_protocol::owned::begin_quorum_epoch_response::tagged_fixture_json(version)
}
"BeginTransactionRecord" => {
krabka_protocol::owned::begin_transaction_record::tagged_fixture_json(version)
}
"BrokerHeartbeatRequest" => {
krabka_protocol::owned::broker_heartbeat_request::tagged_fixture_json(version)
}
"BrokerRegistrationChangeRecord" => {
krabka_protocol::owned::broker_registration_change_record::tagged_fixture_json(version)
}
"CreateTopicsResponse" => {
krabka_protocol::owned::create_topics_response::tagged_fixture_json(version)
}
"EndQuorumEpochResponse" => {
krabka_protocol::owned::end_quorum_epoch_response::tagged_fixture_json(version)
}
"FetchRequest" => krabka_protocol::owned::fetch_request::tagged_fixture_json(version),
"FetchResponse" => krabka_protocol::owned::fetch_response::tagged_fixture_json(version),
"FetchSnapshotRequest" => {
krabka_protocol::owned::fetch_snapshot_request::tagged_fixture_json(version)
}
"FetchSnapshotResponse" => {
krabka_protocol::owned::fetch_snapshot_response::tagged_fixture_json(version)
}
"OffsetCommitValue" => {
krabka_protocol::owned::offset_commit_value::tagged_fixture_json(version)
}
"PartitionChangeRecord" => {
krabka_protocol::owned::partition_change_record::tagged_fixture_json(version)
}
"PartitionRecord" => krabka_protocol::owned::partition_record::tagged_fixture_json(version),
"ProduceResponse" => krabka_protocol::owned::produce_response::tagged_fixture_json(version),
"RegisterBrokerRecord" => {
krabka_protocol::owned::register_broker_record::tagged_fixture_json(version)
}
"RemoteLogSegmentMetadataRecord" => {
krabka_protocol::owned::remote_log_segment_metadata_record::tagged_fixture_json(version)
}
"RemoteLogSegmentMetadataSnapshotRecord" => {
krabka_protocol::owned::remote_log_segment_metadata_snapshot_record::tagged_fixture_json(
version,
)
}
"UpdateRaftVoterResponse" => {
krabka_protocol::owned::update_raft_voter_response::tagged_fixture_json(version)
}
"VoteResponse" => krabka_protocol::owned::vote_response::tagged_fixture_json(version),
_ => panic!("unknown message in tagged_fixture_json_for: {name}"),
}
}
fn roundtrip_0(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"AddOffsetsToTxnRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::add_offsets_to_txn_request::AddOffsetsToTxnRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddOffsetsToTxnResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::add_offsets_to_txn_response::AddOffsetsToTxnResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddPartitionsToTxnRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::add_partitions_to_txn_request::AddPartitionsToTxnRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddPartitionsToTxnResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::add_partitions_to_txn_response::AddPartitionsToTxnResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddRaftVoterRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::add_raft_voter_request::AddRaftVoterRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AddRaftVoterResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::add_raft_voter_response::AddRaftVoterResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_1(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"AllocateProducerIdsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::allocate_producer_ids_request::AllocateProducerIdsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AllocateProducerIdsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::allocate_producer_ids_response::AllocateProducerIdsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterClientQuotasRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_client_quotas_request::AlterClientQuotasRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterClientQuotasResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_client_quotas_response::AlterClientQuotasResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterConfigsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_configs_request::AlterConfigsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterConfigsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_configs_response::AlterConfigsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_2(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"AlterPartitionReassignmentsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_partition_reassignments_request::AlterPartitionReassignmentsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterPartitionReassignmentsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_partition_reassignments_response::AlterPartitionReassignmentsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterPartitionRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::alter_partition_request::AlterPartitionRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterPartitionResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::alter_partition_response::AlterPartitionResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterReplicaLogDirsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_replica_log_dirs_request::AlterReplicaLogDirsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterReplicaLogDirsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_replica_log_dirs_response::AlterReplicaLogDirsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_3(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"AlterShareGroupOffsetsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_share_group_offsets_request::AlterShareGroupOffsetsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterShareGroupOffsetsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_share_group_offsets_response::AlterShareGroupOffsetsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterUserScramCredentialsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_user_scram_credentials_request::AlterUserScramCredentialsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AlterUserScramCredentialsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::alter_user_scram_credentials_response::AlterUserScramCredentialsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ApiVersionsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::api_versions_request::ApiVersionsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ApiVersionsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::api_versions_response::ApiVersionsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_4(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"AssignReplicasToDirsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::assign_replicas_to_dirs_request::AssignReplicasToDirsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"AssignReplicasToDirsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::assign_replicas_to_dirs_response::AssignReplicasToDirsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BeginQuorumEpochRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::begin_quorum_epoch_request::BeginQuorumEpochRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BeginQuorumEpochResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::begin_quorum_epoch_response::BeginQuorumEpochResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BrokerHeartbeatRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::broker_heartbeat_request::BrokerHeartbeatRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BrokerHeartbeatResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::broker_heartbeat_response::BrokerHeartbeatResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_5(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"BrokerRegistrationRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::broker_registration_request::BrokerRegistrationRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"BrokerRegistrationResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::broker_registration_response::BrokerRegistrationResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ConsumerGroupDescribeRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::consumer_group_describe_request::ConsumerGroupDescribeRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ConsumerGroupDescribeResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::consumer_group_describe_response::ConsumerGroupDescribeResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ConsumerGroupHeartbeatRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::consumer_group_heartbeat_request::ConsumerGroupHeartbeatRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ConsumerGroupHeartbeatResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::consumer_group_heartbeat_response::ConsumerGroupHeartbeatResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_6(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"ControllerRegistrationRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::controller_registration_request::ControllerRegistrationRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ControllerRegistrationResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::controller_registration_response::ControllerRegistrationResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateAclsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::create_acls_request::CreateAclsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateAclsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::create_acls_response::CreateAclsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateDelegationTokenRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::create_delegation_token_request::CreateDelegationTokenRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateDelegationTokenResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::create_delegation_token_response::CreateDelegationTokenResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_7(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"CreatePartitionsRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::create_partitions_request::CreatePartitionsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreatePartitionsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::create_partitions_response::CreatePartitionsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateTopicsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::create_topics_request::CreateTopicsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"CreateTopicsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::create_topics_response::CreateTopicsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteAclsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_acls_request::DeleteAclsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteAclsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_acls_response::DeleteAclsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_8(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"DeleteGroupsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_groups_request::DeleteGroupsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteGroupsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_groups_response::DeleteGroupsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteRecordsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_records_request::DeleteRecordsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteRecordsResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::delete_records_response::DeleteRecordsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteShareGroupOffsetsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_share_group_offsets_request::DeleteShareGroupOffsetsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteShareGroupOffsetsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_share_group_offsets_response::DeleteShareGroupOffsetsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_9(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"DeleteShareGroupStateRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_share_group_state_request::DeleteShareGroupStateRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteShareGroupStateResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_share_group_state_response::DeleteShareGroupStateResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteTopicsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_topics_request::DeleteTopicsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DeleteTopicsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::delete_topics_response::DeleteTopicsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeAclsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_acls_request::DescribeAclsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeAclsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_acls_response::DescribeAclsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_10(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"DescribeClientQuotasRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_client_quotas_request::DescribeClientQuotasRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeClientQuotasResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_client_quotas_response::DescribeClientQuotasResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeClusterRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::describe_cluster_request::DescribeClusterRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeClusterResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::describe_cluster_response::DescribeClusterResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeConfigsRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::describe_configs_request::DescribeConfigsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeConfigsResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::describe_configs_response::DescribeConfigsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_11(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"DescribeDelegationTokenRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_delegation_token_request::DescribeDelegationTokenRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeDelegationTokenResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_delegation_token_response::DescribeDelegationTokenResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeGroupsRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::describe_groups_request::DescribeGroupsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeGroupsResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::describe_groups_response::DescribeGroupsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeLogDirsRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::describe_log_dirs_request::DescribeLogDirsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeLogDirsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_log_dirs_response::DescribeLogDirsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_12(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"DescribeProducersRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_producers_request::DescribeProducersRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeProducersResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_producers_response::DescribeProducersResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeQuorumRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::describe_quorum_request::DescribeQuorumRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeQuorumResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::describe_quorum_response::DescribeQuorumResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeShareGroupOffsetsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_share_group_offsets_request::DescribeShareGroupOffsetsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeShareGroupOffsetsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_13(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"DescribeTopicPartitionsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_topic_partitions_request::DescribeTopicPartitionsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeTopicPartitionsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_topic_partitions_response::DescribeTopicPartitionsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeTransactionsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_transactions_request::DescribeTransactionsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeTransactionsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_transactions_response::DescribeTransactionsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeUserScramCredentialsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_user_scram_credentials_request::DescribeUserScramCredentialsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"DescribeUserScramCredentialsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::describe_user_scram_credentials_response::DescribeUserScramCredentialsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_14(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"ElectLeadersRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::elect_leaders_request::ElectLeadersRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ElectLeadersResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::elect_leaders_response::ElectLeadersResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EndQuorumEpochRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::end_quorum_epoch_request::EndQuorumEpochRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EndQuorumEpochResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::end_quorum_epoch_response::EndQuorumEpochResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EndTxnRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::end_txn_request::EndTxnRequest::decode(&mut cur, version)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EndTxnResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::end_txn_response::EndTxnResponse::decode(&mut cur, version)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_15(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"EnvelopeRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::envelope_request::EnvelopeRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"EnvelopeResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::envelope_response::EnvelopeResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ExpireDelegationTokenRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::expire_delegation_token_request::ExpireDelegationTokenRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ExpireDelegationTokenResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::expire_delegation_token_response::ExpireDelegationTokenResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FetchRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::fetch_request::FetchRequest::decode(&mut cur, version)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FetchResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::fetch_response::FetchResponse::decode(&mut cur, version)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_16(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"FetchSnapshotRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::fetch_snapshot_request::FetchSnapshotRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FetchSnapshotResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::fetch_snapshot_response::FetchSnapshotResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FindCoordinatorRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::find_coordinator_request::FindCoordinatorRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"FindCoordinatorResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::find_coordinator_response::FindCoordinatorResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"GetTelemetrySubscriptionsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::get_telemetry_subscriptions_request::GetTelemetrySubscriptionsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"GetTelemetrySubscriptionsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::get_telemetry_subscriptions_response::GetTelemetrySubscriptionsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_17(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"HeartbeatRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::heartbeat_request::HeartbeatRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"HeartbeatResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::heartbeat_response::HeartbeatResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"IncrementalAlterConfigsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::incremental_alter_configs_request::IncrementalAlterConfigsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"IncrementalAlterConfigsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::incremental_alter_configs_response::IncrementalAlterConfigsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"InitProducerIdRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::init_producer_id_request::InitProducerIdRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"InitProducerIdResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::init_producer_id_response::InitProducerIdResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_18(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"InitializeShareGroupStateRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::initialize_share_group_state_request::InitializeShareGroupStateRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"InitializeShareGroupStateResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::initialize_share_group_state_response::InitializeShareGroupStateResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"JoinGroupRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::join_group_request::JoinGroupRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"JoinGroupResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::join_group_response::JoinGroupResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"LeaveGroupRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::leave_group_request::LeaveGroupRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"LeaveGroupResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::leave_group_response::LeaveGroupResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_19(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"ListConfigResourcesRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::list_config_resources_request::ListConfigResourcesRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListConfigResourcesResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::list_config_resources_response::ListConfigResourcesResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListGroupsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::list_groups_request::ListGroupsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListGroupsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::list_groups_response::ListGroupsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListOffsetsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::list_offsets_request::ListOffsetsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListOffsetsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::list_offsets_response::ListOffsetsResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_20(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"ListPartitionReassignmentsRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::list_partition_reassignments_request::ListPartitionReassignmentsRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListPartitionReassignmentsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::list_partition_reassignments_response::ListPartitionReassignmentsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListTransactionsRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::list_transactions_request::ListTransactionsRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ListTransactionsResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::list_transactions_response::ListTransactionsResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"MetadataRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::metadata_request::MetadataRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"MetadataResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::metadata_response::MetadataResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_21(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"OffsetCommitRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::offset_commit_request::OffsetCommitRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetCommitResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::offset_commit_response::OffsetCommitResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetDeleteRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::offset_delete_request::OffsetDeleteRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetDeleteResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::offset_delete_response::OffsetDeleteResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetFetchRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::offset_fetch_request::OffsetFetchRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetFetchResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::offset_fetch_response::OffsetFetchResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_22(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"OffsetForLeaderEpochRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::offset_for_leader_epoch_request::OffsetForLeaderEpochRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"OffsetForLeaderEpochResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::offset_for_leader_epoch_response::OffsetForLeaderEpochResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ProduceRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::produce_request::ProduceRequest::decode(&mut cur, version)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ProduceResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::produce_response::ProduceResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"PushTelemetryRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::push_telemetry_request::PushTelemetryRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"PushTelemetryResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::push_telemetry_response::PushTelemetryResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_23(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"ReadShareGroupStateRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::read_share_group_state_request::ReadShareGroupStateRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ReadShareGroupStateResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::read_share_group_state_response::ReadShareGroupStateResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ReadShareGroupStateSummaryRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::read_share_group_state_summary_request::ReadShareGroupStateSummaryRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ReadShareGroupStateSummaryResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::read_share_group_state_summary_response::ReadShareGroupStateSummaryResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"RemoveRaftVoterRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::remove_raft_voter_request::RemoveRaftVoterRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"RemoveRaftVoterResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::remove_raft_voter_response::RemoveRaftVoterResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_24(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"RenewDelegationTokenRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::renew_delegation_token_request::RenewDelegationTokenRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"RenewDelegationTokenResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::renew_delegation_token_response::RenewDelegationTokenResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"RequestHeader" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::request_header::RequestHeader::decode(&mut cur, version)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ResponseHeader" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::response_header::ResponseHeader::decode(&mut cur, version)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SaslAuthenticateRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::sasl_authenticate_request::SaslAuthenticateRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SaslAuthenticateResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::sasl_authenticate_response::SaslAuthenticateResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_25(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"SaslHandshakeRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::sasl_handshake_request::SaslHandshakeRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SaslHandshakeResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::sasl_handshake_response::SaslHandshakeResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareAcknowledgeRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::share_acknowledge_request::ShareAcknowledgeRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareAcknowledgeResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::share_acknowledge_response::ShareAcknowledgeResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareFetchRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::share_fetch_request::ShareFetchRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareFetchResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::share_fetch_response::ShareFetchResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_26(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"ShareGroupDescribeRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::share_group_describe_request::ShareGroupDescribeRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareGroupDescribeResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::share_group_describe_response::ShareGroupDescribeResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareGroupHeartbeatRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::share_group_heartbeat_request::ShareGroupHeartbeatRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"ShareGroupHeartbeatResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::share_group_heartbeat_response::ShareGroupHeartbeatResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupDescribeRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::streams_group_describe_request::StreamsGroupDescribeRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupDescribeResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::streams_group_describe_response::StreamsGroupDescribeResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_27(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"StreamsGroupHeartbeatRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::streams_group_heartbeat_request::StreamsGroupHeartbeatRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupHeartbeatResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::streams_group_heartbeat_response::StreamsGroupHeartbeatResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupTopologyDescriptionUpdateRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::streams_group_topology_description_update_request::StreamsGroupTopologyDescriptionUpdateRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"StreamsGroupTopologyDescriptionUpdateResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::streams_group_topology_description_update_response::StreamsGroupTopologyDescriptionUpdateResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SyncGroupRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::sync_group_request::SyncGroupRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"SyncGroupResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::sync_group_response::SyncGroupResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_28(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"TxnOffsetCommitRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::txn_offset_commit_request::TxnOffsetCommitRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"TxnOffsetCommitResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::txn_offset_commit_response::TxnOffsetCommitResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UnregisterBrokerRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::unregister_broker_request::UnregisterBrokerRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UnregisterBrokerResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::unregister_broker_response::UnregisterBrokerResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UnregisterControllerRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::unregister_controller_request::UnregisterControllerRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UnregisterControllerResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::unregister_controller_response::UnregisterControllerResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_29(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"UpdateFeaturesRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::update_features_request::UpdateFeaturesRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UpdateFeaturesResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::update_features_response::UpdateFeaturesResponse::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UpdateRaftVoterRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::update_raft_voter_request::UpdateRaftVoterRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"UpdateRaftVoterResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::update_raft_voter_response::UpdateRaftVoterResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"VoteRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::vote_request::VoteRequest::decode(&mut cur, version)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"VoteResponse" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::vote_response::VoteResponse::decode(&mut cur, version)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
fn roundtrip_30(name: &str, version: i16, bytes: &[u8]) -> Option<Vec<u8>> {
use krabka_protocol::Decode;
Some(match name {
"WriteShareGroupStateRequest" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::write_share_group_state_request::WriteShareGroupStateRequest::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"WriteShareGroupStateResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::write_share_group_state_response::WriteShareGroupStateResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"WriteTxnMarkersRequest" => {
let mut cur = bytes;
let msg =
krabka_protocol::owned::write_txn_markers_request::WriteTxnMarkersRequest::decode(
&mut cur, version,
)
.unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
"WriteTxnMarkersResponse" => {
let mut cur = bytes;
let msg = krabka_protocol::owned::write_txn_markers_response::WriteTxnMarkersResponse::decode(&mut cur, version).unwrap();
assert!(cur.is_empty());
let mut buf = BytesMut::new();
msg.encode(&mut buf, version).unwrap();
buf.to_vec()
}
_ => return None,
})
}
#[must_use]
pub fn roundtrip(name: &str, version: i16, bytes: &[u8]) -> Vec<u8> {
let mut result = None;
result = result.or_else(|| roundtrip_0(name, version, bytes));
result = result.or_else(|| roundtrip_1(name, version, bytes));
result = result.or_else(|| roundtrip_2(name, version, bytes));
result = result.or_else(|| roundtrip_3(name, version, bytes));
result = result.or_else(|| roundtrip_4(name, version, bytes));
result = result.or_else(|| roundtrip_5(name, version, bytes));
result = result.or_else(|| roundtrip_6(name, version, bytes));
result = result.or_else(|| roundtrip_7(name, version, bytes));
result = result.or_else(|| roundtrip_8(name, version, bytes));
result = result.or_else(|| roundtrip_9(name, version, bytes));
result = result.or_else(|| roundtrip_10(name, version, bytes));
result = result.or_else(|| roundtrip_11(name, version, bytes));
result = result.or_else(|| roundtrip_12(name, version, bytes));
result = result.or_else(|| roundtrip_13(name, version, bytes));
result = result.or_else(|| roundtrip_14(name, version, bytes));
result = result.or_else(|| roundtrip_15(name, version, bytes));
result = result.or_else(|| roundtrip_16(name, version, bytes));
result = result.or_else(|| roundtrip_17(name, version, bytes));
result = result.or_else(|| roundtrip_18(name, version, bytes));
result = result.or_else(|| roundtrip_19(name, version, bytes));
result = result.or_else(|| roundtrip_20(name, version, bytes));
result = result.or_else(|| roundtrip_21(name, version, bytes));
result = result.or_else(|| roundtrip_22(name, version, bytes));
result = result.or_else(|| roundtrip_23(name, version, bytes));
result = result.or_else(|| roundtrip_24(name, version, bytes));
result = result.or_else(|| roundtrip_25(name, version, bytes));
result = result.or_else(|| roundtrip_26(name, version, bytes));
result = result.or_else(|| roundtrip_27(name, version, bytes));
result = result.or_else(|| roundtrip_28(name, version, bytes));
result = result.or_else(|| roundtrip_29(name, version, bytes));
result = result.or_else(|| roundtrip_30(name, version, bytes));
result.unwrap_or_else(|| panic!("unknown message in roundtrip: {name}"))
}
const REQUEST_FLEX_MIN: &[(&str, i16)] = &[
("AddOffsetsToTxnRequest", 3),
("AddPartitionsToTxnRequest", 3),
("AddRaftVoterRequest", 0),
("AllocateProducerIdsRequest", 0),
("AlterClientQuotasRequest", 1),
("AlterConfigsRequest", 2),
("AlterPartitionReassignmentsRequest", 0),
("AlterPartitionRequest", 0),
("AlterReplicaLogDirsRequest", 2),
("AlterShareGroupOffsetsRequest", 0),
("AlterUserScramCredentialsRequest", 0),
("ApiVersionsRequest", 3),
("AssignReplicasToDirsRequest", 0),
("BeginQuorumEpochRequest", 1),
("BrokerHeartbeatRequest", 0),
("BrokerRegistrationRequest", 0),
("ConsumerGroupDescribeRequest", 0),
("ConsumerGroupHeartbeatRequest", 0),
("ControllerRegistrationRequest", 0),
("CreateAclsRequest", 2),
("CreateDelegationTokenRequest", 2),
("CreatePartitionsRequest", 2),
("CreateTopicsRequest", 5),
("DeleteAclsRequest", 2),
("DeleteGroupsRequest", 2),
("DeleteRecordsRequest", 2),
("DeleteShareGroupOffsetsRequest", 0),
("DeleteShareGroupStateRequest", 0),
("DeleteTopicsRequest", 4),
("DescribeAclsRequest", 2),
("DescribeClientQuotasRequest", 1),
("DescribeClusterRequest", 0),
("DescribeConfigsRequest", 4),
("DescribeDelegationTokenRequest", 2),
("DescribeGroupsRequest", 5),
("DescribeLogDirsRequest", 2),
("DescribeProducersRequest", 0),
("DescribeQuorumRequest", 0),
("DescribeShareGroupOffsetsRequest", 0),
("DescribeTopicPartitionsRequest", 0),
("DescribeTransactionsRequest", 0),
("DescribeUserScramCredentialsRequest", 0),
("ElectLeadersRequest", 2),
("EndQuorumEpochRequest", 1),
("EndTxnRequest", 3),
("EnvelopeRequest", 0),
("ExpireDelegationTokenRequest", 2),
("FetchRequest", 12),
("FetchSnapshotRequest", 0),
("FindCoordinatorRequest", 3),
("GetTelemetrySubscriptionsRequest", 0),
("HeartbeatRequest", 4),
("IncrementalAlterConfigsRequest", 1),
("InitProducerIdRequest", 2),
("InitializeShareGroupStateRequest", 0),
("JoinGroupRequest", 6),
("LeaveGroupRequest", 4),
("ListConfigResourcesRequest", 0),
("ListGroupsRequest", 3),
("ListOffsetsRequest", 6),
("ListPartitionReassignmentsRequest", 0),
("ListTransactionsRequest", 0),
("MetadataRequest", 9),
("OffsetCommitRequest", 8),
("OffsetDeleteRequest", 32767),
("OffsetFetchRequest", 6),
("OffsetForLeaderEpochRequest", 4),
("ProduceRequest", 9),
("PushTelemetryRequest", 0),
("ReadShareGroupStateRequest", 0),
("ReadShareGroupStateSummaryRequest", 0),
("RemoveRaftVoterRequest", 0),
("RenewDelegationTokenRequest", 2),
("SaslAuthenticateRequest", 2),
("SaslHandshakeRequest", 32767),
("ShareAcknowledgeRequest", 0),
("ShareFetchRequest", 0),
("ShareGroupDescribeRequest", 0),
("ShareGroupHeartbeatRequest", 0),
("StreamsGroupDescribeRequest", 0),
("StreamsGroupHeartbeatRequest", 0),
("StreamsGroupTopologyDescriptionUpdateRequest", 0),
("SyncGroupRequest", 4),
("TxnOffsetCommitRequest", 3),
("UnregisterBrokerRequest", 0),
("UnregisterControllerRequest", 0),
("UpdateFeaturesRequest", 0),
("UpdateRaftVoterRequest", 0),
("VoteRequest", 0),
("WriteShareGroupStateRequest", 0),
("WriteTxnMarkersRequest", 1),
];
const RESPONSE_FLEX_MIN: &[(&str, i16)] = &[
("AddOffsetsToTxnResponse", 3),
("AddPartitionsToTxnResponse", 3),
("AddRaftVoterResponse", 0),
("AllocateProducerIdsResponse", 0),
("AlterClientQuotasResponse", 1),
("AlterConfigsResponse", 2),
("AlterPartitionReassignmentsResponse", 0),
("AlterPartitionResponse", 0),
("AlterReplicaLogDirsResponse", 2),
("AlterShareGroupOffsetsResponse", 0),
("AlterUserScramCredentialsResponse", 0),
("AssignReplicasToDirsResponse", 0),
("BeginQuorumEpochResponse", 1),
("BrokerHeartbeatResponse", 0),
("BrokerRegistrationResponse", 0),
("ConsumerGroupDescribeResponse", 0),
("ConsumerGroupHeartbeatResponse", 0),
("ControllerRegistrationResponse", 0),
("CreateAclsResponse", 2),
("CreateDelegationTokenResponse", 2),
("CreatePartitionsResponse", 2),
("CreateTopicsResponse", 5),
("DeleteAclsResponse", 2),
("DeleteGroupsResponse", 2),
("DeleteRecordsResponse", 2),
("DeleteShareGroupOffsetsResponse", 0),
("DeleteShareGroupStateResponse", 0),
("DeleteTopicsResponse", 4),
("DescribeAclsResponse", 2),
("DescribeClientQuotasResponse", 1),
("DescribeClusterResponse", 0),
("DescribeConfigsResponse", 4),
("DescribeDelegationTokenResponse", 2),
("DescribeGroupsResponse", 5),
("DescribeLogDirsResponse", 2),
("DescribeProducersResponse", 0),
("DescribeQuorumResponse", 0),
("DescribeShareGroupOffsetsResponse", 0),
("DescribeTopicPartitionsResponse", 0),
("DescribeTransactionsResponse", 0),
("DescribeUserScramCredentialsResponse", 0),
("ElectLeadersResponse", 2),
("EndQuorumEpochResponse", 1),
("EndTxnResponse", 3),
("EnvelopeResponse", 0),
("ExpireDelegationTokenResponse", 2),
("FetchResponse", 12),
("FetchSnapshotResponse", 0),
("FindCoordinatorResponse", 3),
("GetTelemetrySubscriptionsResponse", 0),
("HeartbeatResponse", 4),
("IncrementalAlterConfigsResponse", 1),
("InitProducerIdResponse", 2),
("InitializeShareGroupStateResponse", 0),
("JoinGroupResponse", 6),
("LeaveGroupResponse", 4),
("ListConfigResourcesResponse", 0),
("ListGroupsResponse", 3),
("ListOffsetsResponse", 6),
("ListPartitionReassignmentsResponse", 0),
("ListTransactionsResponse", 0),
("MetadataResponse", 9),
("OffsetCommitResponse", 8),
("OffsetDeleteResponse", 32767),
("OffsetFetchResponse", 6),
("OffsetForLeaderEpochResponse", 4),
("ProduceResponse", 9),
("PushTelemetryResponse", 0),
("ReadShareGroupStateResponse", 0),
("ReadShareGroupStateSummaryResponse", 0),
("RemoveRaftVoterResponse", 0),
("RenewDelegationTokenResponse", 2),
("SaslAuthenticateResponse", 2),
("SaslHandshakeResponse", 32767),
("ShareAcknowledgeResponse", 0),
("ShareFetchResponse", 0),
("ShareGroupDescribeResponse", 0),
("ShareGroupHeartbeatResponse", 0),
("StreamsGroupDescribeResponse", 0),
("StreamsGroupHeartbeatResponse", 0),
("StreamsGroupTopologyDescriptionUpdateResponse", 0),
("SyncGroupResponse", 4),
("TxnOffsetCommitResponse", 3),
("UnregisterBrokerResponse", 0),
("UnregisterControllerResponse", 0),
("UpdateFeaturesResponse", 0),
("UpdateRaftVoterResponse", 0),
("VoteResponse", 0),
("WriteShareGroupStateResponse", 0),
("WriteTxnMarkersResponse", 1),
];
fn header_flex_min(table: &[(&str, i16)], name: &str, message_type: &str) -> i16 {
table
.iter()
.find_map(|(candidate, minimum)| (*candidate == name).then_some(*minimum))
.unwrap_or_else(|| panic!("unknown {message_type} in header version lookup: {name}"))
}
#[must_use]
pub fn request_header_version(name: &str, version: i16) -> i16 {
if name == "ControlledShutdownRequest" && version == 0 {
return 0;
}
let minimum = header_flex_min(REQUEST_FLEX_MIN, name, "request");
if minimum == i16::MIN || version >= minimum {
2
} else {
1
}
}
#[must_use]
pub fn response_header_version(name: &str, version: i16) -> i16 {
if name == "ApiVersionsResponse" {
return 0;
}
let minimum = header_flex_min(RESPONSE_FLEX_MIN, name, "response");
i16::from(minimum != i16::MIN && version >= minimum)
}
#[must_use]
pub fn strip_frame_header(name: &str, version: i16, is_request: bool, frame: &[u8]) -> Vec<u8> {
use krabka_protocol::Decode;
let mut cur = frame;
if is_request {
let hv = request_header_version(name, version);
krabka_protocol::owned::request_header::RequestHeader::decode(&mut cur, hv).unwrap();
} else {
let hv = response_header_version(name, version);
krabka_protocol::owned::response_header::ResponseHeader::decode(&mut cur, hv).unwrap();
}
cur.to_vec()
}