use std::{error::Error, fmt};
use bytes::BytesMut;
use krabka_protocol::{
Encode, ProtocolError, borrowed,
borrowed::{
begin_transaction_record::BeginTransactionRecord,
broker_registration_change_record::BrokerRegistrationChangeRecord,
offset_commit_value::OffsetCommitValue, partition_change_record::PartitionChangeRecord,
partition_record::PartitionRecord, register_broker_record::RegisterBrokerRecord,
remote_log_segment_metadata_record::RemoteLogSegmentMetadataRecord,
remote_log_segment_metadata_snapshot_record::RemoteLogSegmentMetadataSnapshotRecord,
},
owned,
owned::{
add_offsets_to_txn_request, add_offsets_to_txn_request::AddOffsetsToTxnRequest,
add_offsets_to_txn_response, add_offsets_to_txn_response::AddOffsetsToTxnResponse,
add_partitions_to_txn_request, add_partitions_to_txn_request::AddPartitionsToTxnRequest,
add_partitions_to_txn_response, add_partitions_to_txn_response::AddPartitionsToTxnResponse,
add_raft_voter_request, add_raft_voter_request::AddRaftVoterRequest,
add_raft_voter_response, add_raft_voter_response::AddRaftVoterResponse,
allocate_producer_ids_request, allocate_producer_ids_request::AllocateProducerIdsRequest,
allocate_producer_ids_response,
allocate_producer_ids_response::AllocateProducerIdsResponse, alter_client_quotas_request,
alter_client_quotas_request::AlterClientQuotasRequest, alter_client_quotas_response,
alter_client_quotas_response::AlterClientQuotasResponse, alter_configs_request,
alter_configs_request::AlterConfigsRequest, alter_configs_response,
alter_configs_response::AlterConfigsResponse, alter_partition_reassignments_request,
alter_partition_reassignments_request::AlterPartitionReassignmentsRequest,
alter_partition_reassignments_response,
alter_partition_reassignments_response::AlterPartitionReassignmentsResponse,
alter_partition_request, alter_partition_request::AlterPartitionRequest,
alter_partition_response, alter_partition_response::AlterPartitionResponse,
alter_replica_log_dirs_request, alter_replica_log_dirs_request::AlterReplicaLogDirsRequest,
alter_replica_log_dirs_response,
alter_replica_log_dirs_response::AlterReplicaLogDirsResponse,
alter_share_group_offsets_request,
alter_share_group_offsets_request::AlterShareGroupOffsetsRequest,
alter_share_group_offsets_response,
alter_share_group_offsets_response::AlterShareGroupOffsetsResponse,
alter_user_scram_credentials_request,
alter_user_scram_credentials_request::AlterUserScramCredentialsRequest,
alter_user_scram_credentials_response,
alter_user_scram_credentials_response::AlterUserScramCredentialsResponse,
api_versions_request, api_versions_request::ApiVersionsRequest,
assign_replicas_to_dirs_request,
assign_replicas_to_dirs_request::AssignReplicasToDirsRequest,
assign_replicas_to_dirs_response,
assign_replicas_to_dirs_response::AssignReplicasToDirsResponse, begin_quorum_epoch_request,
begin_quorum_epoch_request::BeginQuorumEpochRequest, begin_transaction_record,
broker_heartbeat_response, broker_heartbeat_response::BrokerHeartbeatResponse,
broker_registration_change_record, broker_registration_request,
broker_registration_request::BrokerRegistrationRequest, broker_registration_response,
broker_registration_response::BrokerRegistrationResponse, consumer_group_describe_request,
consumer_group_describe_request::ConsumerGroupDescribeRequest,
consumer_group_describe_response,
consumer_group_describe_response::ConsumerGroupDescribeResponse,
consumer_group_heartbeat_request,
consumer_group_heartbeat_request::ConsumerGroupHeartbeatRequest,
consumer_group_heartbeat_response,
consumer_group_heartbeat_response::ConsumerGroupHeartbeatResponse,
controller_registration_request,
controller_registration_request::ControllerRegistrationRequest,
controller_registration_response,
controller_registration_response::ControllerRegistrationResponse, create_acls_request,
create_acls_request::CreateAclsRequest, create_acls_response,
create_acls_response::CreateAclsResponse, create_delegation_token_request,
create_delegation_token_request::CreateDelegationTokenRequest,
create_delegation_token_response,
create_delegation_token_response::CreateDelegationTokenResponse, create_partitions_request,
create_partitions_request::CreatePartitionsRequest, create_partitions_response,
create_partitions_response::CreatePartitionsResponse, create_topics_request,
create_topics_request::CreateTopicsRequest, delete_acls_request,
delete_acls_request::DeleteAclsRequest, delete_acls_response,
delete_acls_response::DeleteAclsResponse, delete_groups_request,
delete_groups_request::DeleteGroupsRequest, delete_groups_response,
delete_groups_response::DeleteGroupsResponse, delete_records_request,
delete_records_request::DeleteRecordsRequest, delete_records_response,
delete_records_response::DeleteRecordsResponse, delete_share_group_offsets_request,
delete_share_group_offsets_request::DeleteShareGroupOffsetsRequest,
delete_share_group_offsets_response,
delete_share_group_offsets_response::DeleteShareGroupOffsetsResponse,
delete_share_group_state_request,
delete_share_group_state_request::DeleteShareGroupStateRequest,
delete_share_group_state_response,
delete_share_group_state_response::DeleteShareGroupStateResponse, delete_topics_request,
delete_topics_request::DeleteTopicsRequest, delete_topics_response,
delete_topics_response::DeleteTopicsResponse, describe_acls_request,
describe_acls_request::DescribeAclsRequest, describe_acls_response,
describe_acls_response::DescribeAclsResponse, describe_client_quotas_request,
describe_client_quotas_request::DescribeClientQuotasRequest,
describe_client_quotas_response,
describe_client_quotas_response::DescribeClientQuotasResponse, describe_cluster_request,
describe_cluster_request::DescribeClusterRequest, describe_cluster_response,
describe_cluster_response::DescribeClusterResponse, describe_configs_request,
describe_configs_request::DescribeConfigsRequest, describe_configs_response,
describe_configs_response::DescribeConfigsResponse, describe_delegation_token_request,
describe_delegation_token_request::DescribeDelegationTokenRequest,
describe_delegation_token_response,
describe_delegation_token_response::DescribeDelegationTokenResponse,
describe_groups_request, describe_groups_request::DescribeGroupsRequest,
describe_groups_response, describe_groups_response::DescribeGroupsResponse,
describe_log_dirs_request, describe_log_dirs_request::DescribeLogDirsRequest,
describe_log_dirs_response, describe_log_dirs_response::DescribeLogDirsResponse,
describe_producers_request, describe_producers_request::DescribeProducersRequest,
describe_producers_response, describe_producers_response::DescribeProducersResponse,
describe_quorum_request, describe_quorum_request::DescribeQuorumRequest,
describe_quorum_response, describe_quorum_response::DescribeQuorumResponse,
describe_share_group_offsets_request,
describe_share_group_offsets_request::DescribeShareGroupOffsetsRequest,
describe_share_group_offsets_response,
describe_share_group_offsets_response::DescribeShareGroupOffsetsResponse,
describe_topic_partitions_request,
describe_topic_partitions_request::DescribeTopicPartitionsRequest,
describe_topic_partitions_response,
describe_topic_partitions_response::DescribeTopicPartitionsResponse,
describe_transactions_request, describe_transactions_request::DescribeTransactionsRequest,
describe_transactions_response,
describe_transactions_response::DescribeTransactionsResponse,
describe_user_scram_credentials_request,
describe_user_scram_credentials_request::DescribeUserScramCredentialsRequest,
describe_user_scram_credentials_response,
describe_user_scram_credentials_response::DescribeUserScramCredentialsResponse,
elect_leaders_request, elect_leaders_request::ElectLeadersRequest, elect_leaders_response,
elect_leaders_response::ElectLeadersResponse, end_quorum_epoch_request,
end_quorum_epoch_request::EndQuorumEpochRequest, end_txn_request,
end_txn_request::EndTxnRequest, end_txn_response, end_txn_response::EndTxnResponse,
envelope_request, envelope_request::EnvelopeRequest, envelope_response,
envelope_response::EnvelopeResponse, expire_delegation_token_request,
expire_delegation_token_request::ExpireDelegationTokenRequest,
expire_delegation_token_response,
expire_delegation_token_response::ExpireDelegationTokenResponse, find_coordinator_request,
find_coordinator_request::FindCoordinatorRequest, find_coordinator_response,
find_coordinator_response::FindCoordinatorResponse, get_telemetry_subscriptions_request,
get_telemetry_subscriptions_request::GetTelemetrySubscriptionsRequest,
get_telemetry_subscriptions_response,
get_telemetry_subscriptions_response::GetTelemetrySubscriptionsResponse, heartbeat_request,
heartbeat_request::HeartbeatRequest, heartbeat_response,
heartbeat_response::HeartbeatResponse, incremental_alter_configs_request,
incremental_alter_configs_request::IncrementalAlterConfigsRequest,
incremental_alter_configs_response,
incremental_alter_configs_response::IncrementalAlterConfigsResponse,
init_producer_id_request, init_producer_id_request::InitProducerIdRequest,
init_producer_id_response, init_producer_id_response::InitProducerIdResponse,
initialize_share_group_state_request,
initialize_share_group_state_request::InitializeShareGroupStateRequest,
initialize_share_group_state_response,
initialize_share_group_state_response::InitializeShareGroupStateResponse,
join_group_request, join_group_request::JoinGroupRequest, join_group_response,
join_group_response::JoinGroupResponse, leave_group_request,
leave_group_request::LeaveGroupRequest, leave_group_response,
leave_group_response::LeaveGroupResponse, list_config_resources_request,
list_config_resources_request::ListConfigResourcesRequest, list_config_resources_response,
list_config_resources_response::ListConfigResourcesResponse, list_groups_request,
list_groups_request::ListGroupsRequest, list_groups_response,
list_groups_response::ListGroupsResponse, list_offsets_request,
list_offsets_request::ListOffsetsRequest, list_offsets_response,
list_offsets_response::ListOffsetsResponse, list_partition_reassignments_request,
list_partition_reassignments_request::ListPartitionReassignmentsRequest,
list_partition_reassignments_response,
list_partition_reassignments_response::ListPartitionReassignmentsResponse,
list_transactions_request, list_transactions_request::ListTransactionsRequest,
list_transactions_response, list_transactions_response::ListTransactionsResponse,
metadata_request, metadata_request::MetadataRequest, metadata_response,
metadata_response::MetadataResponse, offset_commit_request,
offset_commit_request::OffsetCommitRequest, offset_commit_response,
offset_commit_response::OffsetCommitResponse, offset_commit_value, offset_delete_request,
offset_delete_request::OffsetDeleteRequest, offset_delete_response,
offset_delete_response::OffsetDeleteResponse, offset_fetch_request,
offset_fetch_request::OffsetFetchRequest, offset_fetch_response,
offset_fetch_response::OffsetFetchResponse, offset_for_leader_epoch_request,
offset_for_leader_epoch_request::OffsetForLeaderEpochRequest,
offset_for_leader_epoch_response,
offset_for_leader_epoch_response::OffsetForLeaderEpochResponse, partition_change_record,
partition_record, produce_request, produce_request::ProduceRequest, push_telemetry_request,
push_telemetry_request::PushTelemetryRequest, push_telemetry_response,
push_telemetry_response::PushTelemetryResponse, read_share_group_state_request,
read_share_group_state_request::ReadShareGroupStateRequest,
read_share_group_state_response,
read_share_group_state_response::ReadShareGroupStateResponse,
read_share_group_state_summary_request,
read_share_group_state_summary_request::ReadShareGroupStateSummaryRequest,
read_share_group_state_summary_response,
read_share_group_state_summary_response::ReadShareGroupStateSummaryResponse,
register_broker_record, remote_log_segment_metadata_record,
remote_log_segment_metadata_snapshot_record, remove_raft_voter_request,
remove_raft_voter_request::RemoveRaftVoterRequest, remove_raft_voter_response,
remove_raft_voter_response::RemoveRaftVoterResponse, renew_delegation_token_request,
renew_delegation_token_request::RenewDelegationTokenRequest,
renew_delegation_token_response,
renew_delegation_token_response::RenewDelegationTokenResponse, request_header,
request_header::RequestHeader, response_header, response_header::ResponseHeader,
sasl_authenticate_request, sasl_authenticate_request::SaslAuthenticateRequest,
sasl_authenticate_response, sasl_authenticate_response::SaslAuthenticateResponse,
sasl_handshake_request, sasl_handshake_request::SaslHandshakeRequest,
sasl_handshake_response, sasl_handshake_response::SaslHandshakeResponse,
share_acknowledge_request, share_acknowledge_request::ShareAcknowledgeRequest,
share_acknowledge_response, share_acknowledge_response::ShareAcknowledgeResponse,
share_fetch_request, share_fetch_request::ShareFetchRequest, share_fetch_response,
share_fetch_response::ShareFetchResponse, share_group_describe_request,
share_group_describe_request::ShareGroupDescribeRequest, share_group_describe_response,
share_group_describe_response::ShareGroupDescribeResponse, share_group_heartbeat_request,
share_group_heartbeat_request::ShareGroupHeartbeatRequest, share_group_heartbeat_response,
share_group_heartbeat_response::ShareGroupHeartbeatResponse,
streams_group_describe_request,
streams_group_describe_request::StreamsGroupDescribeRequest,
streams_group_describe_response,
streams_group_describe_response::StreamsGroupDescribeResponse,
streams_group_heartbeat_request,
streams_group_heartbeat_request::StreamsGroupHeartbeatRequest,
streams_group_heartbeat_response,
streams_group_heartbeat_response::StreamsGroupHeartbeatResponse,
streams_group_topology_description_update_request,
streams_group_topology_description_update_request::StreamsGroupTopologyDescriptionUpdateRequest,
streams_group_topology_description_update_response,
streams_group_topology_description_update_response::StreamsGroupTopologyDescriptionUpdateResponse,
sync_group_request, sync_group_request::SyncGroupRequest, sync_group_response,
sync_group_response::SyncGroupResponse, txn_offset_commit_request,
txn_offset_commit_request::TxnOffsetCommitRequest, txn_offset_commit_response,
txn_offset_commit_response::TxnOffsetCommitResponse, unregister_broker_request,
unregister_broker_request::UnregisterBrokerRequest, unregister_broker_response,
unregister_broker_response::UnregisterBrokerResponse, unregister_controller_request,
unregister_controller_request::UnregisterControllerRequest, unregister_controller_response,
unregister_controller_response::UnregisterControllerResponse, update_features_request,
update_features_request::UpdateFeaturesRequest, update_features_response,
update_features_response::UpdateFeaturesResponse, update_raft_voter_request,
update_raft_voter_request::UpdateRaftVoterRequest, vote_request, vote_request::VoteRequest,
write_share_group_state_request,
write_share_group_state_request::WriteShareGroupStateRequest,
write_share_group_state_response,
write_share_group_state_response::WriteShareGroupStateResponse, write_txn_markers_request,
write_txn_markers_request::WriteTxnMarkersRequest, write_txn_markers_response,
write_txn_markers_response::WriteTxnMarkersResponse,
},
};
#[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 type EncodedPair = (Vec<u8>, Vec<u8>);
#[derive(Debug)]
pub enum TableError {
UnknownMessage(String),
Protocol(ProtocolError),
TrailingBytes { name: String, remaining: usize },
}
impl fmt::Display for TableError {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
match self {
Self::UnknownMessage(name) => write!(f, "unknown message {name}"),
Self::Protocol(e) => write!(f, "{e}"),
Self::TrailingBytes { name, remaining } => {
write!(f, "{name}: {remaining} bytes left after decode")
}
}
}
}
impl Error for TableError {
fn source(&self) -> Option<&(dyn Error + 'static)> {
match self {
Self::Protocol(e) => Some(e),
Self::UnknownMessage(_) | Self::TrailingBytes { .. } => None,
}
}
}
impl From<ProtocolError> for TableError {
fn from(e: ProtocolError) -> Self {
Self::Protocol(e)
}
}
fn encode_with<T: Encode>(message: &T, version: i16) -> Result<Vec<u8>, TableError> {
let mut buf = BytesMut::new();
message.encode(&mut buf, version)?;
Ok(buf.to_vec())
}
fn expect_consumed(name: &str, rest: &[u8]) -> Result<(), TableError> {
if rest.is_empty() {
Ok(())
} else {
Err(TableError::TrailingBytes {
name: name.to_owned(),
remaining: rest.len(),
})
}
}
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) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"AddOffsetsToTxnRequest" => encode_with(&AddOffsetsToTxnRequest::default(), version)?,
"AddOffsetsToTxnResponse" => encode_with(&AddOffsetsToTxnResponse::default(), version)?,
"AddPartitionsToTxnRequest" => encode_with(&AddPartitionsToTxnRequest::default(), version)?,
"AddPartitionsToTxnResponse" => {
encode_with(&AddPartitionsToTxnResponse::default(), version)?
}
"AddRaftVoterRequest" => encode_with(&AddRaftVoterRequest::default(), version)?,
"AddRaftVoterResponse" => encode_with(&AddRaftVoterResponse::default(), version)?,
"AllocateProducerIdsRequest" => {
encode_with(&AllocateProducerIdsRequest::default(), version)?
}
"AllocateProducerIdsResponse" => {
encode_with(&AllocateProducerIdsResponse::default(), version)?
}
_ => return Ok(None),
}))
}
fn encode_default_1(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"AlterClientQuotasRequest" => encode_with(&AlterClientQuotasRequest::default(), version)?,
"AlterClientQuotasResponse" => encode_with(&AlterClientQuotasResponse::default(), version)?,
"AlterConfigsRequest" => encode_with(&AlterConfigsRequest::default(), version)?,
"AlterConfigsResponse" => encode_with(&AlterConfigsResponse::default(), version)?,
"AlterPartitionReassignmentsRequest" => {
encode_with(&AlterPartitionReassignmentsRequest::default(), version)?
}
"AlterPartitionReassignmentsResponse" => {
encode_with(&AlterPartitionReassignmentsResponse::default(), version)?
}
"AlterPartitionRequest" => encode_with(&AlterPartitionRequest::default(), version)?,
"AlterPartitionResponse" => encode_with(&AlterPartitionResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_2(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"AlterReplicaLogDirsRequest" => {
encode_with(&AlterReplicaLogDirsRequest::default(), version)?
}
"AlterReplicaLogDirsResponse" => {
encode_with(&AlterReplicaLogDirsResponse::default(), version)?
}
"AlterShareGroupOffsetsRequest" => {
encode_with(&AlterShareGroupOffsetsRequest::default(), version)?
}
"AlterShareGroupOffsetsResponse" => {
encode_with(&AlterShareGroupOffsetsResponse::default(), version)?
}
"AlterUserScramCredentialsRequest" => {
encode_with(&AlterUserScramCredentialsRequest::default(), version)?
}
"AlterUserScramCredentialsResponse" => {
encode_with(&AlterUserScramCredentialsResponse::default(), version)?
}
"ApiVersionsRequest" => encode_with(&ApiVersionsRequest::default(), version)?,
"ApiVersionsResponse" => encode_with(
&owned::api_versions_response::ApiVersionsResponse::default(),
version,
)?,
_ => return Ok(None),
}))
}
fn encode_default_3(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"AssignReplicasToDirsRequest" => {
encode_with(&AssignReplicasToDirsRequest::default(), version)?
}
"AssignReplicasToDirsResponse" => {
encode_with(&AssignReplicasToDirsResponse::default(), version)?
}
"BeginQuorumEpochRequest" => encode_with(&BeginQuorumEpochRequest::default(), version)?,
"BeginQuorumEpochResponse" => encode_with(
&owned::begin_quorum_epoch_response::BeginQuorumEpochResponse::default(),
version,
)?,
"BrokerHeartbeatRequest" => encode_with(
&owned::broker_heartbeat_request::BrokerHeartbeatRequest::default(),
version,
)?,
"BrokerHeartbeatResponse" => encode_with(&BrokerHeartbeatResponse::default(), version)?,
"BrokerRegistrationRequest" => encode_with(&BrokerRegistrationRequest::default(), version)?,
"BrokerRegistrationResponse" => {
encode_with(&BrokerRegistrationResponse::default(), version)?
}
_ => return Ok(None),
}))
}
fn encode_default_4(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"ConsumerGroupDescribeRequest" => {
encode_with(&ConsumerGroupDescribeRequest::default(), version)?
}
"ConsumerGroupDescribeResponse" => {
encode_with(&ConsumerGroupDescribeResponse::default(), version)?
}
"ConsumerGroupHeartbeatRequest" => {
encode_with(&ConsumerGroupHeartbeatRequest::default(), version)?
}
"ConsumerGroupHeartbeatResponse" => {
encode_with(&ConsumerGroupHeartbeatResponse::default(), version)?
}
"ControllerRegistrationRequest" => {
encode_with(&ControllerRegistrationRequest::default(), version)?
}
"ControllerRegistrationResponse" => {
encode_with(&ControllerRegistrationResponse::default(), version)?
}
"CreateAclsRequest" => encode_with(&CreateAclsRequest::default(), version)?,
"CreateAclsResponse" => encode_with(&CreateAclsResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_5(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"CreateDelegationTokenRequest" => {
encode_with(&CreateDelegationTokenRequest::default(), version)?
}
"CreateDelegationTokenResponse" => {
encode_with(&CreateDelegationTokenResponse::default(), version)?
}
"CreatePartitionsRequest" => encode_with(&CreatePartitionsRequest::default(), version)?,
"CreatePartitionsResponse" => encode_with(&CreatePartitionsResponse::default(), version)?,
"CreateTopicsRequest" => encode_with(&CreateTopicsRequest::default(), version)?,
"CreateTopicsResponse" => encode_with(
&owned::create_topics_response::CreateTopicsResponse::default(),
version,
)?,
"DeleteAclsRequest" => encode_with(&DeleteAclsRequest::default(), version)?,
"DeleteAclsResponse" => encode_with(&DeleteAclsResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_6(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DeleteGroupsRequest" => encode_with(&DeleteGroupsRequest::default(), version)?,
"DeleteGroupsResponse" => encode_with(&DeleteGroupsResponse::default(), version)?,
"DeleteRecordsRequest" => encode_with(&DeleteRecordsRequest::default(), version)?,
"DeleteRecordsResponse" => encode_with(&DeleteRecordsResponse::default(), version)?,
"DeleteShareGroupOffsetsRequest" => {
encode_with(&DeleteShareGroupOffsetsRequest::default(), version)?
}
"DeleteShareGroupOffsetsResponse" => {
encode_with(&DeleteShareGroupOffsetsResponse::default(), version)?
}
"DeleteShareGroupStateRequest" => {
encode_with(&DeleteShareGroupStateRequest::default(), version)?
}
"DeleteShareGroupStateResponse" => {
encode_with(&DeleteShareGroupStateResponse::default(), version)?
}
_ => return Ok(None),
}))
}
fn encode_default_7(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DeleteTopicsRequest" => encode_with(&DeleteTopicsRequest::default(), version)?,
"DeleteTopicsResponse" => encode_with(&DeleteTopicsResponse::default(), version)?,
"DescribeAclsRequest" => encode_with(&DescribeAclsRequest::default(), version)?,
"DescribeAclsResponse" => encode_with(&DescribeAclsResponse::default(), version)?,
"DescribeClientQuotasRequest" => {
encode_with(&DescribeClientQuotasRequest::default(), version)?
}
"DescribeClientQuotasResponse" => {
encode_with(&DescribeClientQuotasResponse::default(), version)?
}
"DescribeClusterRequest" => encode_with(&DescribeClusterRequest::default(), version)?,
"DescribeClusterResponse" => encode_with(&DescribeClusterResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_8(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DescribeConfigsRequest" => encode_with(&DescribeConfigsRequest::default(), version)?,
"DescribeConfigsResponse" => encode_with(&DescribeConfigsResponse::default(), version)?,
"DescribeDelegationTokenRequest" => {
encode_with(&DescribeDelegationTokenRequest::default(), version)?
}
"DescribeDelegationTokenResponse" => {
encode_with(&DescribeDelegationTokenResponse::default(), version)?
}
"DescribeGroupsRequest" => encode_with(&DescribeGroupsRequest::default(), version)?,
"DescribeGroupsResponse" => encode_with(&DescribeGroupsResponse::default(), version)?,
"DescribeLogDirsRequest" => encode_with(&DescribeLogDirsRequest::default(), version)?,
"DescribeLogDirsResponse" => encode_with(&DescribeLogDirsResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_9(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DescribeProducersRequest" => encode_with(&DescribeProducersRequest::default(), version)?,
"DescribeProducersResponse" => encode_with(&DescribeProducersResponse::default(), version)?,
"DescribeQuorumRequest" => encode_with(&DescribeQuorumRequest::default(), version)?,
"DescribeQuorumResponse" => encode_with(&DescribeQuorumResponse::default(), version)?,
"DescribeShareGroupOffsetsRequest" => {
encode_with(&DescribeShareGroupOffsetsRequest::default(), version)?
}
"DescribeShareGroupOffsetsResponse" => {
encode_with(&DescribeShareGroupOffsetsResponse::default(), version)?
}
"DescribeTopicPartitionsRequest" => {
encode_with(&DescribeTopicPartitionsRequest::default(), version)?
}
"DescribeTopicPartitionsResponse" => {
encode_with(&DescribeTopicPartitionsResponse::default(), version)?
}
_ => return Ok(None),
}))
}
fn encode_default_10(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DescribeTransactionsRequest" => {
encode_with(&DescribeTransactionsRequest::default(), version)?
}
"DescribeTransactionsResponse" => {
encode_with(&DescribeTransactionsResponse::default(), version)?
}
"DescribeUserScramCredentialsRequest" => {
encode_with(&DescribeUserScramCredentialsRequest::default(), version)?
}
"DescribeUserScramCredentialsResponse" => {
encode_with(&DescribeUserScramCredentialsResponse::default(), version)?
}
"ElectLeadersRequest" => encode_with(&ElectLeadersRequest::default(), version)?,
"ElectLeadersResponse" => encode_with(&ElectLeadersResponse::default(), version)?,
"EndQuorumEpochRequest" => encode_with(&EndQuorumEpochRequest::default(), version)?,
"EndQuorumEpochResponse" => encode_with(
&owned::end_quorum_epoch_response::EndQuorumEpochResponse::default(),
version,
)?,
_ => return Ok(None),
}))
}
fn encode_default_11(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"EndTxnRequest" => encode_with(&EndTxnRequest::default(), version)?,
"EndTxnResponse" => encode_with(&EndTxnResponse::default(), version)?,
"EnvelopeRequest" => encode_with(&EnvelopeRequest::default(), version)?,
"EnvelopeResponse" => encode_with(&EnvelopeResponse::default(), version)?,
"ExpireDelegationTokenRequest" => {
encode_with(&ExpireDelegationTokenRequest::default(), version)?
}
"ExpireDelegationTokenResponse" => {
encode_with(&ExpireDelegationTokenResponse::default(), version)?
}
"FetchRequest" => encode_with(&owned::fetch_request::FetchRequest::default(), version)?,
"FetchResponse" => encode_with(&owned::fetch_response::FetchResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_12(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"FetchSnapshotRequest" => encode_with(
&owned::fetch_snapshot_request::FetchSnapshotRequest::default(),
version,
)?,
"FetchSnapshotResponse" => encode_with(
&owned::fetch_snapshot_response::FetchSnapshotResponse::default(),
version,
)?,
"FindCoordinatorRequest" => encode_with(&FindCoordinatorRequest::default(), version)?,
"FindCoordinatorResponse" => encode_with(&FindCoordinatorResponse::default(), version)?,
"GetTelemetrySubscriptionsRequest" => {
encode_with(&GetTelemetrySubscriptionsRequest::default(), version)?
}
"GetTelemetrySubscriptionsResponse" => {
encode_with(&GetTelemetrySubscriptionsResponse::default(), version)?
}
"HeartbeatRequest" => encode_with(&HeartbeatRequest::default(), version)?,
"HeartbeatResponse" => encode_with(&HeartbeatResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_13(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"IncrementalAlterConfigsRequest" => {
encode_with(&IncrementalAlterConfigsRequest::default(), version)?
}
"IncrementalAlterConfigsResponse" => {
encode_with(&IncrementalAlterConfigsResponse::default(), version)?
}
"InitProducerIdRequest" => encode_with(&InitProducerIdRequest::default(), version)?,
"InitProducerIdResponse" => encode_with(&InitProducerIdResponse::default(), version)?,
"InitializeShareGroupStateRequest" => {
encode_with(&InitializeShareGroupStateRequest::default(), version)?
}
"InitializeShareGroupStateResponse" => {
encode_with(&InitializeShareGroupStateResponse::default(), version)?
}
"JoinGroupRequest" => encode_with(&JoinGroupRequest::default(), version)?,
"JoinGroupResponse" => encode_with(&JoinGroupResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_14(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"LeaveGroupRequest" => encode_with(&LeaveGroupRequest::default(), version)?,
"LeaveGroupResponse" => encode_with(&LeaveGroupResponse::default(), version)?,
"ListConfigResourcesRequest" => {
encode_with(&ListConfigResourcesRequest::default(), version)?
}
"ListConfigResourcesResponse" => {
encode_with(&ListConfigResourcesResponse::default(), version)?
}
"ListGroupsRequest" => encode_with(&ListGroupsRequest::default(), version)?,
"ListGroupsResponse" => encode_with(&ListGroupsResponse::default(), version)?,
"ListOffsetsRequest" => encode_with(&ListOffsetsRequest::default(), version)?,
"ListOffsetsResponse" => encode_with(&ListOffsetsResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_15(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"ListPartitionReassignmentsRequest" => {
encode_with(&ListPartitionReassignmentsRequest::default(), version)?
}
"ListPartitionReassignmentsResponse" => {
encode_with(&ListPartitionReassignmentsResponse::default(), version)?
}
"ListTransactionsRequest" => encode_with(&ListTransactionsRequest::default(), version)?,
"ListTransactionsResponse" => encode_with(&ListTransactionsResponse::default(), version)?,
"MetadataRequest" => encode_with(&MetadataRequest::default(), version)?,
"MetadataResponse" => encode_with(&MetadataResponse::default(), version)?,
"OffsetCommitRequest" => encode_with(&OffsetCommitRequest::default(), version)?,
"OffsetCommitResponse" => encode_with(&OffsetCommitResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_16(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"OffsetDeleteRequest" => encode_with(&OffsetDeleteRequest::default(), version)?,
"OffsetDeleteResponse" => encode_with(&OffsetDeleteResponse::default(), version)?,
"OffsetFetchRequest" => encode_with(&OffsetFetchRequest::default(), version)?,
"OffsetFetchResponse" => encode_with(&OffsetFetchResponse::default(), version)?,
"OffsetForLeaderEpochRequest" => {
encode_with(&OffsetForLeaderEpochRequest::default(), version)?
}
"OffsetForLeaderEpochResponse" => {
encode_with(&OffsetForLeaderEpochResponse::default(), version)?
}
"ProduceRequest" => encode_with(&ProduceRequest::default(), version)?,
"ProduceResponse" => encode_with(
&owned::produce_response::ProduceResponse::default(),
version,
)?,
_ => return Ok(None),
}))
}
fn encode_default_17(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"PushTelemetryRequest" => encode_with(&PushTelemetryRequest::default(), version)?,
"PushTelemetryResponse" => encode_with(&PushTelemetryResponse::default(), version)?,
"ReadShareGroupStateRequest" => {
encode_with(&ReadShareGroupStateRequest::default(), version)?
}
"ReadShareGroupStateResponse" => {
encode_with(&ReadShareGroupStateResponse::default(), version)?
}
"ReadShareGroupStateSummaryRequest" => {
encode_with(&ReadShareGroupStateSummaryRequest::default(), version)?
}
"ReadShareGroupStateSummaryResponse" => {
encode_with(&ReadShareGroupStateSummaryResponse::default(), version)?
}
"RemoveRaftVoterRequest" => encode_with(&RemoveRaftVoterRequest::default(), version)?,
"RemoveRaftVoterResponse" => encode_with(&RemoveRaftVoterResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_18(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"RenewDelegationTokenRequest" => {
encode_with(&RenewDelegationTokenRequest::default(), version)?
}
"RenewDelegationTokenResponse" => {
encode_with(&RenewDelegationTokenResponse::default(), version)?
}
"RequestHeader" => encode_with(&RequestHeader::default(), version)?,
"ResponseHeader" => encode_with(&ResponseHeader::default(), version)?,
"SaslAuthenticateRequest" => encode_with(&SaslAuthenticateRequest::default(), version)?,
"SaslAuthenticateResponse" => encode_with(&SaslAuthenticateResponse::default(), version)?,
"SaslHandshakeRequest" => encode_with(&SaslHandshakeRequest::default(), version)?,
"SaslHandshakeResponse" => encode_with(&SaslHandshakeResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_19(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"ShareAcknowledgeRequest" => encode_with(&ShareAcknowledgeRequest::default(), version)?,
"ShareAcknowledgeResponse" => encode_with(&ShareAcknowledgeResponse::default(), version)?,
"ShareFetchRequest" => encode_with(&ShareFetchRequest::default(), version)?,
"ShareFetchResponse" => encode_with(&ShareFetchResponse::default(), version)?,
"ShareGroupDescribeRequest" => encode_with(&ShareGroupDescribeRequest::default(), version)?,
"ShareGroupDescribeResponse" => {
encode_with(&ShareGroupDescribeResponse::default(), version)?
}
"ShareGroupHeartbeatRequest" => {
encode_with(&ShareGroupHeartbeatRequest::default(), version)?
}
"ShareGroupHeartbeatResponse" => {
encode_with(&ShareGroupHeartbeatResponse::default(), version)?
}
_ => return Ok(None),
}))
}
fn encode_default_20(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"StreamsGroupDescribeRequest" => {
encode_with(&StreamsGroupDescribeRequest::default(), version)?
}
"StreamsGroupDescribeResponse" => {
encode_with(&StreamsGroupDescribeResponse::default(), version)?
}
"StreamsGroupHeartbeatRequest" => {
encode_with(&StreamsGroupHeartbeatRequest::default(), version)?
}
"StreamsGroupHeartbeatResponse" => {
encode_with(&StreamsGroupHeartbeatResponse::default(), version)?
}
"StreamsGroupTopologyDescriptionUpdateRequest" => encode_with(
&StreamsGroupTopologyDescriptionUpdateRequest::default(),
version,
)?,
"StreamsGroupTopologyDescriptionUpdateResponse" => encode_with(
&StreamsGroupTopologyDescriptionUpdateResponse::default(),
version,
)?,
"SyncGroupRequest" => encode_with(&SyncGroupRequest::default(), version)?,
"SyncGroupResponse" => encode_with(&SyncGroupResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_21(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"TxnOffsetCommitRequest" => encode_with(&TxnOffsetCommitRequest::default(), version)?,
"TxnOffsetCommitResponse" => encode_with(&TxnOffsetCommitResponse::default(), version)?,
"UnregisterBrokerRequest" => encode_with(&UnregisterBrokerRequest::default(), version)?,
"UnregisterBrokerResponse" => encode_with(&UnregisterBrokerResponse::default(), version)?,
"UnregisterControllerRequest" => {
encode_with(&UnregisterControllerRequest::default(), version)?
}
"UnregisterControllerResponse" => {
encode_with(&UnregisterControllerResponse::default(), version)?
}
"UpdateFeaturesRequest" => encode_with(&UpdateFeaturesRequest::default(), version)?,
"UpdateFeaturesResponse" => encode_with(&UpdateFeaturesResponse::default(), version)?,
_ => return Ok(None),
}))
}
fn encode_default_22(name: &str, version: i16) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"UpdateRaftVoterRequest" => encode_with(&UpdateRaftVoterRequest::default(), version)?,
"UpdateRaftVoterResponse" => encode_with(
&owned::update_raft_voter_response::UpdateRaftVoterResponse::default(),
version,
)?,
"VoteRequest" => encode_with(&VoteRequest::default(), version)?,
"VoteResponse" => encode_with(&owned::vote_response::VoteResponse::default(), version)?,
"WriteShareGroupStateRequest" => {
encode_with(&WriteShareGroupStateRequest::default(), version)?
}
"WriteShareGroupStateResponse" => {
encode_with(&WriteShareGroupStateResponse::default(), version)?
}
"WriteTxnMarkersRequest" => encode_with(&WriteTxnMarkersRequest::default(), version)?,
"WriteTxnMarkersResponse" => encode_with(&WriteTxnMarkersResponse::default(), version)?,
_ => return Ok(None),
}))
}
pub fn encode_default(name: &str, version: i16) -> Result<Vec<u8>, TableError> {
if let Some(value) = encode_default_0(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_1(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_2(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_3(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_4(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_5(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_6(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_7(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_8(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_9(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_10(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_11(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_12(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_13(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_14(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_15(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_16(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_17(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_18(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_19(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_20(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_21(name, version)? {
return Ok(value);
}
if let Some(value) = encode_default_22(name, version)? {
return Ok(value);
}
Err(TableError::UnknownMessage(name.to_owned()))
}
fn default_json_for_0(name: &str, version: i16) -> Result<Option<::serde_json::Value>, TableError> {
Ok(Some(match name {
"AddOffsetsToTxnRequest" => add_offsets_to_txn_request::default_json(version),
"AddOffsetsToTxnResponse" => add_offsets_to_txn_response::default_json(version),
"AddPartitionsToTxnRequest" => add_partitions_to_txn_request::default_json(version),
"AddPartitionsToTxnResponse" => add_partitions_to_txn_response::default_json(version),
"AddRaftVoterRequest" => add_raft_voter_request::default_json(version),
"AddRaftVoterResponse" => add_raft_voter_response::default_json(version),
"AllocateProducerIdsRequest" => allocate_producer_ids_request::default_json(version),
"AllocateProducerIdsResponse" => allocate_producer_ids_response::default_json(version),
"AlterClientQuotasRequest" => alter_client_quotas_request::default_json(version),
"AlterClientQuotasResponse" => alter_client_quotas_response::default_json(version),
"AlterConfigsRequest" => alter_configs_request::default_json(version),
"AlterConfigsResponse" => alter_configs_response::default_json(version),
"AlterPartitionReassignmentsRequest" => {
alter_partition_reassignments_request::default_json(version)
}
"AlterPartitionReassignmentsResponse" => {
alter_partition_reassignments_response::default_json(version)
}
"AlterPartitionRequest" => alter_partition_request::default_json(version),
"AlterPartitionResponse" => alter_partition_response::default_json(version),
"AlterReplicaLogDirsRequest" => alter_replica_log_dirs_request::default_json(version),
"AlterReplicaLogDirsResponse" => alter_replica_log_dirs_response::default_json(version),
"AlterShareGroupOffsetsRequest" => alter_share_group_offsets_request::default_json(version),
"AlterShareGroupOffsetsResponse" => {
alter_share_group_offsets_response::default_json(version)
}
"AlterUserScramCredentialsRequest" => {
alter_user_scram_credentials_request::default_json(version)
}
"AlterUserScramCredentialsResponse" => {
alter_user_scram_credentials_response::default_json(version)
}
"ApiVersionsRequest" => api_versions_request::default_json(version),
"ApiVersionsResponse" => owned::api_versions_response::default_json(version),
"AssignReplicasToDirsRequest" => assign_replicas_to_dirs_request::default_json(version),
"AssignReplicasToDirsResponse" => assign_replicas_to_dirs_response::default_json(version),
"BeginQuorumEpochRequest" => begin_quorum_epoch_request::default_json(version),
"BeginQuorumEpochResponse" => owned::begin_quorum_epoch_response::default_json(version),
"BrokerHeartbeatRequest" => owned::broker_heartbeat_request::default_json(version),
"BrokerHeartbeatResponse" => broker_heartbeat_response::default_json(version),
"BrokerRegistrationRequest" => broker_registration_request::default_json(version),
"BrokerRegistrationResponse" => broker_registration_response::default_json(version),
"ConsumerGroupDescribeRequest" => consumer_group_describe_request::default_json(version),
"ConsumerGroupDescribeResponse" => consumer_group_describe_response::default_json(version),
"ConsumerGroupHeartbeatRequest" => consumer_group_heartbeat_request::default_json(version),
"ConsumerGroupHeartbeatResponse" => {
consumer_group_heartbeat_response::default_json(version)
}
"ControllerRegistrationRequest" => controller_registration_request::default_json(version),
"ControllerRegistrationResponse" => controller_registration_response::default_json(version),
"CreateAclsRequest" => create_acls_request::default_json(version),
"CreateAclsResponse" => create_acls_response::default_json(version),
"CreateDelegationTokenRequest" => create_delegation_token_request::default_json(version),
"CreateDelegationTokenResponse" => create_delegation_token_response::default_json(version),
"CreatePartitionsRequest" => create_partitions_request::default_json(version),
"CreatePartitionsResponse" => create_partitions_response::default_json(version),
"CreateTopicsRequest" => create_topics_request::default_json(version),
"CreateTopicsResponse" => owned::create_topics_response::default_json(version),
"DeleteAclsRequest" => delete_acls_request::default_json(version),
"DeleteAclsResponse" => delete_acls_response::default_json(version),
"DeleteGroupsRequest" => delete_groups_request::default_json(version),
"DeleteGroupsResponse" => delete_groups_response::default_json(version),
"DeleteRecordsRequest" => delete_records_request::default_json(version),
"DeleteRecordsResponse" => delete_records_response::default_json(version),
"DeleteShareGroupOffsetsRequest" => {
delete_share_group_offsets_request::default_json(version)
}
"DeleteShareGroupOffsetsResponse" => {
delete_share_group_offsets_response::default_json(version)
}
"DeleteShareGroupStateRequest" => delete_share_group_state_request::default_json(version),
"DeleteShareGroupStateResponse" => delete_share_group_state_response::default_json(version),
"DeleteTopicsRequest" => delete_topics_request::default_json(version),
"DeleteTopicsResponse" => delete_topics_response::default_json(version),
"DescribeAclsRequest" => describe_acls_request::default_json(version),
"DescribeAclsResponse" => describe_acls_response::default_json(version),
_ => return Ok(None),
}))
}
fn default_json_for_1(name: &str, version: i16) -> Result<Option<::serde_json::Value>, TableError> {
Ok(Some(match name {
"DescribeClientQuotasRequest" => describe_client_quotas_request::default_json(version),
"DescribeClientQuotasResponse" => describe_client_quotas_response::default_json(version),
"DescribeClusterRequest" => describe_cluster_request::default_json(version),
"DescribeClusterResponse" => describe_cluster_response::default_json(version),
"DescribeConfigsRequest" => describe_configs_request::default_json(version),
"DescribeConfigsResponse" => describe_configs_response::default_json(version),
"DescribeDelegationTokenRequest" => {
describe_delegation_token_request::default_json(version)
}
"DescribeDelegationTokenResponse" => {
describe_delegation_token_response::default_json(version)
}
"DescribeGroupsRequest" => describe_groups_request::default_json(version),
"DescribeGroupsResponse" => describe_groups_response::default_json(version),
"DescribeLogDirsRequest" => describe_log_dirs_request::default_json(version),
"DescribeLogDirsResponse" => describe_log_dirs_response::default_json(version),
"DescribeProducersRequest" => describe_producers_request::default_json(version),
"DescribeProducersResponse" => describe_producers_response::default_json(version),
"DescribeQuorumRequest" => describe_quorum_request::default_json(version),
"DescribeQuorumResponse" => describe_quorum_response::default_json(version),
"DescribeShareGroupOffsetsRequest" => {
describe_share_group_offsets_request::default_json(version)
}
"DescribeShareGroupOffsetsResponse" => {
describe_share_group_offsets_response::default_json(version)
}
"DescribeTopicPartitionsRequest" => {
describe_topic_partitions_request::default_json(version)
}
"DescribeTopicPartitionsResponse" => {
describe_topic_partitions_response::default_json(version)
}
"DescribeTransactionsRequest" => describe_transactions_request::default_json(version),
"DescribeTransactionsResponse" => describe_transactions_response::default_json(version),
"DescribeUserScramCredentialsRequest" => {
describe_user_scram_credentials_request::default_json(version)
}
"DescribeUserScramCredentialsResponse" => {
describe_user_scram_credentials_response::default_json(version)
}
"ElectLeadersRequest" => elect_leaders_request::default_json(version),
"ElectLeadersResponse" => elect_leaders_response::default_json(version),
"EndQuorumEpochRequest" => end_quorum_epoch_request::default_json(version),
"EndQuorumEpochResponse" => owned::end_quorum_epoch_response::default_json(version),
"EndTxnRequest" => end_txn_request::default_json(version),
"EndTxnResponse" => end_txn_response::default_json(version),
"EnvelopeRequest" => envelope_request::default_json(version),
"EnvelopeResponse" => envelope_response::default_json(version),
"ExpireDelegationTokenRequest" => expire_delegation_token_request::default_json(version),
"ExpireDelegationTokenResponse" => expire_delegation_token_response::default_json(version),
"FetchRequest" => owned::fetch_request::default_json(version),
"FetchResponse" => owned::fetch_response::default_json(version),
"FetchSnapshotRequest" => owned::fetch_snapshot_request::default_json(version),
"FetchSnapshotResponse" => owned::fetch_snapshot_response::default_json(version),
"FindCoordinatorRequest" => find_coordinator_request::default_json(version),
"FindCoordinatorResponse" => find_coordinator_response::default_json(version),
"GetTelemetrySubscriptionsRequest" => {
get_telemetry_subscriptions_request::default_json(version)
}
"GetTelemetrySubscriptionsResponse" => {
get_telemetry_subscriptions_response::default_json(version)
}
"HeartbeatRequest" => heartbeat_request::default_json(version),
"HeartbeatResponse" => heartbeat_response::default_json(version),
"IncrementalAlterConfigsRequest" => {
incremental_alter_configs_request::default_json(version)
}
"IncrementalAlterConfigsResponse" => {
incremental_alter_configs_response::default_json(version)
}
"InitProducerIdRequest" => init_producer_id_request::default_json(version),
"InitProducerIdResponse" => init_producer_id_response::default_json(version),
"InitializeShareGroupStateRequest" => {
initialize_share_group_state_request::default_json(version)
}
"InitializeShareGroupStateResponse" => {
initialize_share_group_state_response::default_json(version)
}
"JoinGroupRequest" => join_group_request::default_json(version),
"JoinGroupResponse" => join_group_response::default_json(version),
"LeaveGroupRequest" => leave_group_request::default_json(version),
"LeaveGroupResponse" => leave_group_response::default_json(version),
"ListConfigResourcesRequest" => list_config_resources_request::default_json(version),
"ListConfigResourcesResponse" => list_config_resources_response::default_json(version),
"ListGroupsRequest" => list_groups_request::default_json(version),
"ListGroupsResponse" => list_groups_response::default_json(version),
"ListOffsetsRequest" => list_offsets_request::default_json(version),
"ListOffsetsResponse" => list_offsets_response::default_json(version),
_ => return Ok(None),
}))
}
fn default_json_for_2(name: &str, version: i16) -> Result<Option<::serde_json::Value>, TableError> {
Ok(Some(match name {
"ListPartitionReassignmentsRequest" => {
list_partition_reassignments_request::default_json(version)
}
"ListPartitionReassignmentsResponse" => {
list_partition_reassignments_response::default_json(version)
}
"ListTransactionsRequest" => list_transactions_request::default_json(version),
"ListTransactionsResponse" => list_transactions_response::default_json(version),
"MetadataRequest" => metadata_request::default_json(version),
"MetadataResponse" => metadata_response::default_json(version),
"OffsetCommitRequest" => offset_commit_request::default_json(version),
"OffsetCommitResponse" => offset_commit_response::default_json(version),
"OffsetDeleteRequest" => offset_delete_request::default_json(version),
"OffsetDeleteResponse" => offset_delete_response::default_json(version),
"OffsetFetchRequest" => offset_fetch_request::default_json(version),
"OffsetFetchResponse" => offset_fetch_response::default_json(version),
"OffsetForLeaderEpochRequest" => offset_for_leader_epoch_request::default_json(version),
"OffsetForLeaderEpochResponse" => offset_for_leader_epoch_response::default_json(version),
"ProduceRequest" => produce_request::default_json(version),
"ProduceResponse" => owned::produce_response::default_json(version),
"PushTelemetryRequest" => push_telemetry_request::default_json(version),
"PushTelemetryResponse" => push_telemetry_response::default_json(version),
"ReadShareGroupStateRequest" => read_share_group_state_request::default_json(version),
"ReadShareGroupStateResponse" => read_share_group_state_response::default_json(version),
"ReadShareGroupStateSummaryRequest" => {
read_share_group_state_summary_request::default_json(version)
}
"ReadShareGroupStateSummaryResponse" => {
read_share_group_state_summary_response::default_json(version)
}
"RemoveRaftVoterRequest" => remove_raft_voter_request::default_json(version),
"RemoveRaftVoterResponse" => remove_raft_voter_response::default_json(version),
"RenewDelegationTokenRequest" => renew_delegation_token_request::default_json(version),
"RenewDelegationTokenResponse" => renew_delegation_token_response::default_json(version),
"RequestHeader" => request_header::default_json(version),
"ResponseHeader" => response_header::default_json(version),
"SaslAuthenticateRequest" => sasl_authenticate_request::default_json(version),
"SaslAuthenticateResponse" => sasl_authenticate_response::default_json(version),
"SaslHandshakeRequest" => sasl_handshake_request::default_json(version),
"SaslHandshakeResponse" => sasl_handshake_response::default_json(version),
"ShareAcknowledgeRequest" => share_acknowledge_request::default_json(version),
"ShareAcknowledgeResponse" => share_acknowledge_response::default_json(version),
"ShareFetchRequest" => share_fetch_request::default_json(version),
"ShareFetchResponse" => share_fetch_response::default_json(version),
"ShareGroupDescribeRequest" => share_group_describe_request::default_json(version),
"ShareGroupDescribeResponse" => share_group_describe_response::default_json(version),
"ShareGroupHeartbeatRequest" => share_group_heartbeat_request::default_json(version),
"ShareGroupHeartbeatResponse" => share_group_heartbeat_response::default_json(version),
"StreamsGroupDescribeRequest" => streams_group_describe_request::default_json(version),
"StreamsGroupDescribeResponse" => streams_group_describe_response::default_json(version),
"StreamsGroupHeartbeatRequest" => streams_group_heartbeat_request::default_json(version),
"StreamsGroupHeartbeatResponse" => streams_group_heartbeat_response::default_json(version),
"StreamsGroupTopologyDescriptionUpdateRequest" => {
streams_group_topology_description_update_request::default_json(version)
}
"StreamsGroupTopologyDescriptionUpdateResponse" => {
streams_group_topology_description_update_response::default_json(version)
}
"SyncGroupRequest" => sync_group_request::default_json(version),
"SyncGroupResponse" => sync_group_response::default_json(version),
"TxnOffsetCommitRequest" => txn_offset_commit_request::default_json(version),
"TxnOffsetCommitResponse" => txn_offset_commit_response::default_json(version),
"UnregisterBrokerRequest" => unregister_broker_request::default_json(version),
"UnregisterBrokerResponse" => unregister_broker_response::default_json(version),
"UnregisterControllerRequest" => unregister_controller_request::default_json(version),
"UnregisterControllerResponse" => unregister_controller_response::default_json(version),
"UpdateFeaturesRequest" => update_features_request::default_json(version),
"UpdateFeaturesResponse" => update_features_response::default_json(version),
"UpdateRaftVoterRequest" => update_raft_voter_request::default_json(version),
"UpdateRaftVoterResponse" => owned::update_raft_voter_response::default_json(version),
"VoteRequest" => vote_request::default_json(version),
"VoteResponse" => owned::vote_response::default_json(version),
_ => return Ok(None),
}))
}
fn default_json_for_3(name: &str, version: i16) -> Result<Option<::serde_json::Value>, TableError> {
Ok(Some(match name {
"WriteShareGroupStateRequest" => write_share_group_state_request::default_json(version),
"WriteShareGroupStateResponse" => write_share_group_state_response::default_json(version),
"WriteTxnMarkersRequest" => write_txn_markers_request::default_json(version),
"WriteTxnMarkersResponse" => write_txn_markers_response::default_json(version),
_ => return Ok(None),
}))
}
pub fn default_json_for(name: &str, version: i16) -> Result<::serde_json::Value, TableError> {
if let Some(value) = default_json_for_0(name, version)? {
return Ok(value);
}
if let Some(value) = default_json_for_1(name, version)? {
return Ok(value);
}
if let Some(value) = default_json_for_2(name, version)? {
return Ok(value);
}
if let Some(value) = default_json_for_3(name, version)? {
return Ok(value);
}
Err(TableError::UnknownMessage(name.to_owned()))
}
#[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_tagged_fixture_0(name: &str, version: i16) -> Result<Option<EncodedPair>, TableError> {
Ok(Some(match name {
"ApiVersionsResponse" => {
let owned = owned::api_versions_response::tagged_fixture();
let max = owned::api_versions_response::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::api_versions_response::ApiVersionsResponse as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"BeginQuorumEpochResponse" => {
let owned = owned::begin_quorum_epoch_response::tagged_fixture();
let max = owned::begin_quorum_epoch_response::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::begin_quorum_epoch_response::BeginQuorumEpochResponse as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"BeginTransactionRecord" => {
let owned = begin_transaction_record::tagged_fixture();
let max = begin_transaction_record::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed =
<BeginTransactionRecord as krabka_protocol::DecodeBorrow>::decode_borrow(
&mut cur, max,
)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"BrokerHeartbeatRequest" => {
let owned = owned::broker_heartbeat_request::tagged_fixture();
let max = owned::broker_heartbeat_request::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::broker_heartbeat_request::BrokerHeartbeatRequest as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"BrokerRegistrationChangeRecord" => {
let owned = broker_registration_change_record::tagged_fixture();
let max = broker_registration_change_record::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed =
<BrokerRegistrationChangeRecord as krabka_protocol::DecodeBorrow>::decode_borrow(
&mut cur, max,
)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"CreateTopicsResponse" => {
let owned = owned::create_topics_response::tagged_fixture();
let max = owned::create_topics_response::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::create_topics_response::CreateTopicsResponse as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
_ => return Ok(None),
}))
}
fn encode_tagged_fixture_1(name: &str, version: i16) -> Result<Option<EncodedPair>, TableError> {
Ok(Some(match name {
"EndQuorumEpochResponse" => {
let owned = owned::end_quorum_epoch_response::tagged_fixture();
let max = owned::end_quorum_epoch_response::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::end_quorum_epoch_response::EndQuorumEpochResponse as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"FetchRequest" => {
let owned = owned::fetch_request::tagged_fixture();
let max = owned::fetch_request::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::fetch_request::FetchRequest as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"FetchResponse" => {
let owned = owned::fetch_response::tagged_fixture();
let max = owned::fetch_response::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::fetch_response::FetchResponse as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"FetchSnapshotRequest" => {
let owned = owned::fetch_snapshot_request::tagged_fixture();
let max = owned::fetch_snapshot_request::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::fetch_snapshot_request::FetchSnapshotRequest as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"FetchSnapshotResponse" => {
let owned = owned::fetch_snapshot_response::tagged_fixture();
let max = owned::fetch_snapshot_response::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::fetch_snapshot_response::FetchSnapshotResponse as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"OffsetCommitValue" => {
let owned = offset_commit_value::tagged_fixture();
let max = offset_commit_value::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed =
<OffsetCommitValue as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
_ => return Ok(None),
}))
}
fn encode_tagged_fixture_2(name: &str, version: i16) -> Result<Option<EncodedPair>, TableError> {
Ok(Some(match name {
"PartitionChangeRecord" => {
let owned = partition_change_record::tagged_fixture();
let max = partition_change_record::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <PartitionChangeRecord as krabka_protocol::DecodeBorrow>::decode_borrow(
&mut cur, max,
)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"PartitionRecord" => {
let owned = partition_record::tagged_fixture();
let max = partition_record::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed =
<PartitionRecord as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"ProduceResponse" => {
let owned = owned::produce_response::tagged_fixture();
let max = owned::produce_response::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::produce_response::ProduceResponse as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"RegisterBrokerRecord" => {
let owned = register_broker_record::tagged_fixture();
let max = register_broker_record::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <RegisterBrokerRecord as krabka_protocol::DecodeBorrow>::decode_borrow(
&mut cur, max,
)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"RemoteLogSegmentMetadataRecord" => {
let owned = remote_log_segment_metadata_record::tagged_fixture();
let max = remote_log_segment_metadata_record::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed =
<RemoteLogSegmentMetadataRecord as krabka_protocol::DecodeBorrow>::decode_borrow(
&mut cur, max,
)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"RemoteLogSegmentMetadataSnapshotRecord" => {
let owned = remote_log_segment_metadata_snapshot_record::tagged_fixture();
let max = remote_log_segment_metadata_snapshot_record::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <RemoteLogSegmentMetadataSnapshotRecord as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
_ => return Ok(None),
}))
}
fn encode_tagged_fixture_3(name: &str, version: i16) -> Result<Option<EncodedPair>, TableError> {
Ok(Some(match name {
"UpdateRaftVoterResponse" => {
let owned = owned::update_raft_voter_response::tagged_fixture();
let max = owned::update_raft_voter_response::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::update_raft_voter_response::UpdateRaftVoterResponse as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
"VoteResponse" => {
let owned = owned::vote_response::tagged_fixture();
let max = owned::vote_response::MAX_VERSION;
let full = encode_with(&owned, max)?;
let mut cur = full.as_slice();
let borrowed = <borrowed::vote_response::VoteResponse as krabka_protocol::DecodeBorrow>::decode_borrow(&mut cur, max)?;
expect_consumed(name, cur)?;
(
encode_with(&owned, version)?,
encode_with(&borrowed, version)?,
)
}
_ => return Ok(None),
}))
}
pub fn encode_tagged_fixture(name: &str, version: i16) -> Result<EncodedPair, TableError> {
if let Some(value) = encode_tagged_fixture_0(name, version)? {
return Ok(value);
}
if let Some(value) = encode_tagged_fixture_1(name, version)? {
return Ok(value);
}
if let Some(value) = encode_tagged_fixture_2(name, version)? {
return Ok(value);
}
if let Some(value) = encode_tagged_fixture_3(name, version)? {
return Ok(value);
}
Err(TableError::UnknownMessage(name.to_owned()))
}
pub fn tagged_fixture_json_for(
name: &str,
version: i16,
) -> Result<::serde_json::Value, TableError> {
match name {
"ApiVersionsResponse" => Ok(owned::api_versions_response::tagged_fixture_json(version)),
"BeginQuorumEpochResponse" => Ok(owned::begin_quorum_epoch_response::tagged_fixture_json(
version,
)),
"BeginTransactionRecord" => Ok(begin_transaction_record::tagged_fixture_json(version)),
"BrokerHeartbeatRequest" => Ok(owned::broker_heartbeat_request::tagged_fixture_json(
version,
)),
"BrokerRegistrationChangeRecord" => Ok(
broker_registration_change_record::tagged_fixture_json(version),
),
"CreateTopicsResponse" => Ok(owned::create_topics_response::tagged_fixture_json(version)),
"EndQuorumEpochResponse" => Ok(owned::end_quorum_epoch_response::tagged_fixture_json(
version,
)),
"FetchRequest" => Ok(owned::fetch_request::tagged_fixture_json(version)),
"FetchResponse" => Ok(owned::fetch_response::tagged_fixture_json(version)),
"FetchSnapshotRequest" => Ok(owned::fetch_snapshot_request::tagged_fixture_json(version)),
"FetchSnapshotResponse" => Ok(owned::fetch_snapshot_response::tagged_fixture_json(version)),
"OffsetCommitValue" => Ok(offset_commit_value::tagged_fixture_json(version)),
"PartitionChangeRecord" => Ok(partition_change_record::tagged_fixture_json(version)),
"PartitionRecord" => Ok(partition_record::tagged_fixture_json(version)),
"ProduceResponse" => Ok(owned::produce_response::tagged_fixture_json(version)),
"RegisterBrokerRecord" => Ok(register_broker_record::tagged_fixture_json(version)),
"RemoteLogSegmentMetadataRecord" => Ok(
remote_log_segment_metadata_record::tagged_fixture_json(version),
),
"RemoteLogSegmentMetadataSnapshotRecord" => {
Ok(remote_log_segment_metadata_snapshot_record::tagged_fixture_json(version))
}
"UpdateRaftVoterResponse" => Ok(owned::update_raft_voter_response::tagged_fixture_json(
version,
)),
"VoteResponse" => Ok(owned::vote_response::tagged_fixture_json(version)),
_ => Err(TableError::UnknownMessage(name.to_owned())),
}
}
fn roundtrip_0(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"AddOffsetsToTxnRequest" => {
let mut cur = bytes;
let msg =
<AddOffsetsToTxnRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AddOffsetsToTxnResponse" => {
let mut cur = bytes;
let msg =
<AddOffsetsToTxnResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AddPartitionsToTxnRequest" => {
let mut cur = bytes;
let msg =
<AddPartitionsToTxnRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AddPartitionsToTxnResponse" => {
let mut cur = bytes;
let msg =
<AddPartitionsToTxnResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AddRaftVoterRequest" => {
let mut cur = bytes;
let msg = <AddRaftVoterRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AddRaftVoterResponse" => {
let mut cur = bytes;
let msg = <AddRaftVoterResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_1(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"AllocateProducerIdsRequest" => {
let mut cur = bytes;
let msg =
<AllocateProducerIdsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AllocateProducerIdsResponse" => {
let mut cur = bytes;
let msg = <AllocateProducerIdsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterClientQuotasRequest" => {
let mut cur = bytes;
let msg =
<AlterClientQuotasRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterClientQuotasResponse" => {
let mut cur = bytes;
let msg =
<AlterClientQuotasResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterConfigsRequest" => {
let mut cur = bytes;
let msg = <AlterConfigsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterConfigsResponse" => {
let mut cur = bytes;
let msg = <AlterConfigsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_2(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"AlterPartitionReassignmentsRequest" => {
let mut cur = bytes;
let msg = <AlterPartitionReassignmentsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterPartitionReassignmentsResponse" => {
let mut cur = bytes;
let msg = <AlterPartitionReassignmentsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterPartitionRequest" => {
let mut cur = bytes;
let msg =
<AlterPartitionRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterPartitionResponse" => {
let mut cur = bytes;
let msg =
<AlterPartitionResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterReplicaLogDirsRequest" => {
let mut cur = bytes;
let msg =
<AlterReplicaLogDirsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterReplicaLogDirsResponse" => {
let mut cur = bytes;
let msg = <AlterReplicaLogDirsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_3(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"AlterShareGroupOffsetsRequest" => {
let mut cur = bytes;
let msg = <AlterShareGroupOffsetsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterShareGroupOffsetsResponse" => {
let mut cur = bytes;
let msg = <AlterShareGroupOffsetsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterUserScramCredentialsRequest" => {
let mut cur = bytes;
let msg = <AlterUserScramCredentialsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AlterUserScramCredentialsResponse" => {
let mut cur = bytes;
let msg = <AlterUserScramCredentialsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ApiVersionsRequest" => {
let mut cur = bytes;
let msg = <ApiVersionsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ApiVersionsResponse" => {
let mut cur = bytes;
let msg = <owned::api_versions_response::ApiVersionsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_4(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"AssignReplicasToDirsRequest" => {
let mut cur = bytes;
let msg = <AssignReplicasToDirsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"AssignReplicasToDirsResponse" => {
let mut cur = bytes;
let msg = <AssignReplicasToDirsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"BeginQuorumEpochRequest" => {
let mut cur = bytes;
let msg =
<BeginQuorumEpochRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"BeginQuorumEpochResponse" => {
let mut cur = bytes;
let msg = <owned::begin_quorum_epoch_response::BeginQuorumEpochResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"BrokerHeartbeatRequest" => {
let mut cur = bytes;
let msg = <owned::broker_heartbeat_request::BrokerHeartbeatRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"BrokerHeartbeatResponse" => {
let mut cur = bytes;
let msg =
<BrokerHeartbeatResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_5(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"BrokerRegistrationRequest" => {
let mut cur = bytes;
let msg =
<BrokerRegistrationRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"BrokerRegistrationResponse" => {
let mut cur = bytes;
let msg =
<BrokerRegistrationResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ConsumerGroupDescribeRequest" => {
let mut cur = bytes;
let msg = <ConsumerGroupDescribeRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ConsumerGroupDescribeResponse" => {
let mut cur = bytes;
let msg = <ConsumerGroupDescribeResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ConsumerGroupHeartbeatRequest" => {
let mut cur = bytes;
let msg = <ConsumerGroupHeartbeatRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ConsumerGroupHeartbeatResponse" => {
let mut cur = bytes;
let msg = <ConsumerGroupHeartbeatResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_6(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"ControllerRegistrationRequest" => {
let mut cur = bytes;
let msg = <ControllerRegistrationRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ControllerRegistrationResponse" => {
let mut cur = bytes;
let msg = <ControllerRegistrationResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"CreateAclsRequest" => {
let mut cur = bytes;
let msg = <CreateAclsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"CreateAclsResponse" => {
let mut cur = bytes;
let msg = <CreateAclsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"CreateDelegationTokenRequest" => {
let mut cur = bytes;
let msg = <CreateDelegationTokenRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"CreateDelegationTokenResponse" => {
let mut cur = bytes;
let msg = <CreateDelegationTokenResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_7(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"CreatePartitionsRequest" => {
let mut cur = bytes;
let msg =
<CreatePartitionsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"CreatePartitionsResponse" => {
let mut cur = bytes;
let msg =
<CreatePartitionsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"CreateTopicsRequest" => {
let mut cur = bytes;
let msg = <CreateTopicsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"CreateTopicsResponse" => {
let mut cur = bytes;
let msg = <owned::create_topics_response::CreateTopicsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteAclsRequest" => {
let mut cur = bytes;
let msg = <DeleteAclsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteAclsResponse" => {
let mut cur = bytes;
let msg = <DeleteAclsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_8(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DeleteGroupsRequest" => {
let mut cur = bytes;
let msg = <DeleteGroupsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteGroupsResponse" => {
let mut cur = bytes;
let msg = <DeleteGroupsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteRecordsRequest" => {
let mut cur = bytes;
let msg = <DeleteRecordsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteRecordsResponse" => {
let mut cur = bytes;
let msg =
<DeleteRecordsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteShareGroupOffsetsRequest" => {
let mut cur = bytes;
let msg = <DeleteShareGroupOffsetsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteShareGroupOffsetsResponse" => {
let mut cur = bytes;
let msg = <DeleteShareGroupOffsetsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_9(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DeleteShareGroupStateRequest" => {
let mut cur = bytes;
let msg = <DeleteShareGroupStateRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteShareGroupStateResponse" => {
let mut cur = bytes;
let msg = <DeleteShareGroupStateResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteTopicsRequest" => {
let mut cur = bytes;
let msg = <DeleteTopicsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DeleteTopicsResponse" => {
let mut cur = bytes;
let msg = <DeleteTopicsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeAclsRequest" => {
let mut cur = bytes;
let msg = <DescribeAclsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeAclsResponse" => {
let mut cur = bytes;
let msg = <DescribeAclsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_10(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DescribeClientQuotasRequest" => {
let mut cur = bytes;
let msg = <DescribeClientQuotasRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeClientQuotasResponse" => {
let mut cur = bytes;
let msg = <DescribeClientQuotasResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeClusterRequest" => {
let mut cur = bytes;
let msg =
<DescribeClusterRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeClusterResponse" => {
let mut cur = bytes;
let msg =
<DescribeClusterResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeConfigsRequest" => {
let mut cur = bytes;
let msg =
<DescribeConfigsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeConfigsResponse" => {
let mut cur = bytes;
let msg =
<DescribeConfigsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_11(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DescribeDelegationTokenRequest" => {
let mut cur = bytes;
let msg = <DescribeDelegationTokenRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeDelegationTokenResponse" => {
let mut cur = bytes;
let msg = <DescribeDelegationTokenResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeGroupsRequest" => {
let mut cur = bytes;
let msg =
<DescribeGroupsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeGroupsResponse" => {
let mut cur = bytes;
let msg =
<DescribeGroupsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeLogDirsRequest" => {
let mut cur = bytes;
let msg =
<DescribeLogDirsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeLogDirsResponse" => {
let mut cur = bytes;
let msg =
<DescribeLogDirsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_12(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DescribeProducersRequest" => {
let mut cur = bytes;
let msg =
<DescribeProducersRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeProducersResponse" => {
let mut cur = bytes;
let msg =
<DescribeProducersResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeQuorumRequest" => {
let mut cur = bytes;
let msg =
<DescribeQuorumRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeQuorumResponse" => {
let mut cur = bytes;
let msg =
<DescribeQuorumResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeShareGroupOffsetsRequest" => {
let mut cur = bytes;
let msg = <DescribeShareGroupOffsetsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeShareGroupOffsetsResponse" => {
let mut cur = bytes;
let msg = <DescribeShareGroupOffsetsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_13(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"DescribeTopicPartitionsRequest" => {
let mut cur = bytes;
let msg = <DescribeTopicPartitionsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeTopicPartitionsResponse" => {
let mut cur = bytes;
let msg = <DescribeTopicPartitionsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeTransactionsRequest" => {
let mut cur = bytes;
let msg = <DescribeTransactionsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeTransactionsResponse" => {
let mut cur = bytes;
let msg = <DescribeTransactionsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeUserScramCredentialsRequest" => {
let mut cur = bytes;
let msg = <DescribeUserScramCredentialsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"DescribeUserScramCredentialsResponse" => {
let mut cur = bytes;
let msg = <DescribeUserScramCredentialsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_14(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"ElectLeadersRequest" => {
let mut cur = bytes;
let msg = <ElectLeadersRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ElectLeadersResponse" => {
let mut cur = bytes;
let msg = <ElectLeadersResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"EndQuorumEpochRequest" => {
let mut cur = bytes;
let msg =
<EndQuorumEpochRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"EndQuorumEpochResponse" => {
let mut cur = bytes;
let msg = <owned::end_quorum_epoch_response::EndQuorumEpochResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"EndTxnRequest" => {
let mut cur = bytes;
let msg = <EndTxnRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"EndTxnResponse" => {
let mut cur = bytes;
let msg = <EndTxnResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_15(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"EnvelopeRequest" => {
let mut cur = bytes;
let msg = <EnvelopeRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"EnvelopeResponse" => {
let mut cur = bytes;
let msg = <EnvelopeResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ExpireDelegationTokenRequest" => {
let mut cur = bytes;
let msg = <ExpireDelegationTokenRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ExpireDelegationTokenResponse" => {
let mut cur = bytes;
let msg = <ExpireDelegationTokenResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"FetchRequest" => {
let mut cur = bytes;
let msg = <owned::fetch_request::FetchRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"FetchResponse" => {
let mut cur = bytes;
let msg = <owned::fetch_response::FetchResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_16(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"FetchSnapshotRequest" => {
let mut cur = bytes;
let msg = <owned::fetch_snapshot_request::FetchSnapshotRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"FetchSnapshotResponse" => {
let mut cur = bytes;
let msg = <owned::fetch_snapshot_response::FetchSnapshotResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"FindCoordinatorRequest" => {
let mut cur = bytes;
let msg =
<FindCoordinatorRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"FindCoordinatorResponse" => {
let mut cur = bytes;
let msg =
<FindCoordinatorResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"GetTelemetrySubscriptionsRequest" => {
let mut cur = bytes;
let msg = <GetTelemetrySubscriptionsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"GetTelemetrySubscriptionsResponse" => {
let mut cur = bytes;
let msg = <GetTelemetrySubscriptionsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_17(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"HeartbeatRequest" => {
let mut cur = bytes;
let msg = <HeartbeatRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"HeartbeatResponse" => {
let mut cur = bytes;
let msg = <HeartbeatResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"IncrementalAlterConfigsRequest" => {
let mut cur = bytes;
let msg = <IncrementalAlterConfigsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"IncrementalAlterConfigsResponse" => {
let mut cur = bytes;
let msg = <IncrementalAlterConfigsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"InitProducerIdRequest" => {
let mut cur = bytes;
let msg =
<InitProducerIdRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"InitProducerIdResponse" => {
let mut cur = bytes;
let msg =
<InitProducerIdResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_18(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"InitializeShareGroupStateRequest" => {
let mut cur = bytes;
let msg = <InitializeShareGroupStateRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"InitializeShareGroupStateResponse" => {
let mut cur = bytes;
let msg = <InitializeShareGroupStateResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"JoinGroupRequest" => {
let mut cur = bytes;
let msg = <JoinGroupRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"JoinGroupResponse" => {
let mut cur = bytes;
let msg = <JoinGroupResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"LeaveGroupRequest" => {
let mut cur = bytes;
let msg = <LeaveGroupRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"LeaveGroupResponse" => {
let mut cur = bytes;
let msg = <LeaveGroupResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_19(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"ListConfigResourcesRequest" => {
let mut cur = bytes;
let msg =
<ListConfigResourcesRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ListConfigResourcesResponse" => {
let mut cur = bytes;
let msg = <ListConfigResourcesResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ListGroupsRequest" => {
let mut cur = bytes;
let msg = <ListGroupsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ListGroupsResponse" => {
let mut cur = bytes;
let msg = <ListGroupsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ListOffsetsRequest" => {
let mut cur = bytes;
let msg = <ListOffsetsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ListOffsetsResponse" => {
let mut cur = bytes;
let msg = <ListOffsetsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_20(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"ListPartitionReassignmentsRequest" => {
let mut cur = bytes;
let msg = <ListPartitionReassignmentsRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ListPartitionReassignmentsResponse" => {
let mut cur = bytes;
let msg = <ListPartitionReassignmentsResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ListTransactionsRequest" => {
let mut cur = bytes;
let msg =
<ListTransactionsRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ListTransactionsResponse" => {
let mut cur = bytes;
let msg =
<ListTransactionsResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"MetadataRequest" => {
let mut cur = bytes;
let msg = <MetadataRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"MetadataResponse" => {
let mut cur = bytes;
let msg = <MetadataResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_21(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"OffsetCommitRequest" => {
let mut cur = bytes;
let msg = <OffsetCommitRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"OffsetCommitResponse" => {
let mut cur = bytes;
let msg = <OffsetCommitResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"OffsetDeleteRequest" => {
let mut cur = bytes;
let msg = <OffsetDeleteRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"OffsetDeleteResponse" => {
let mut cur = bytes;
let msg = <OffsetDeleteResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"OffsetFetchRequest" => {
let mut cur = bytes;
let msg = <OffsetFetchRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"OffsetFetchResponse" => {
let mut cur = bytes;
let msg = <OffsetFetchResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_22(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"OffsetForLeaderEpochRequest" => {
let mut cur = bytes;
let msg = <OffsetForLeaderEpochRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"OffsetForLeaderEpochResponse" => {
let mut cur = bytes;
let msg = <OffsetForLeaderEpochResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ProduceRequest" => {
let mut cur = bytes;
let msg = <ProduceRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ProduceResponse" => {
let mut cur = bytes;
let msg =
<owned::produce_response::ProduceResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"PushTelemetryRequest" => {
let mut cur = bytes;
let msg = <PushTelemetryRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"PushTelemetryResponse" => {
let mut cur = bytes;
let msg =
<PushTelemetryResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_23(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"ReadShareGroupStateRequest" => {
let mut cur = bytes;
let msg =
<ReadShareGroupStateRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ReadShareGroupStateResponse" => {
let mut cur = bytes;
let msg = <ReadShareGroupStateResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ReadShareGroupStateSummaryRequest" => {
let mut cur = bytes;
let msg = <ReadShareGroupStateSummaryRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ReadShareGroupStateSummaryResponse" => {
let mut cur = bytes;
let msg = <ReadShareGroupStateSummaryResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"RemoveRaftVoterRequest" => {
let mut cur = bytes;
let msg =
<RemoveRaftVoterRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"RemoveRaftVoterResponse" => {
let mut cur = bytes;
let msg =
<RemoveRaftVoterResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_24(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"RenewDelegationTokenRequest" => {
let mut cur = bytes;
let msg = <RenewDelegationTokenRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"RenewDelegationTokenResponse" => {
let mut cur = bytes;
let msg = <RenewDelegationTokenResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"RequestHeader" => {
let mut cur = bytes;
let msg = <RequestHeader as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ResponseHeader" => {
let mut cur = bytes;
let msg = <ResponseHeader as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"SaslAuthenticateRequest" => {
let mut cur = bytes;
let msg =
<SaslAuthenticateRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"SaslAuthenticateResponse" => {
let mut cur = bytes;
let msg =
<SaslAuthenticateResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_25(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"SaslHandshakeRequest" => {
let mut cur = bytes;
let msg = <SaslHandshakeRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"SaslHandshakeResponse" => {
let mut cur = bytes;
let msg =
<SaslHandshakeResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ShareAcknowledgeRequest" => {
let mut cur = bytes;
let msg =
<ShareAcknowledgeRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ShareAcknowledgeResponse" => {
let mut cur = bytes;
let msg =
<ShareAcknowledgeResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ShareFetchRequest" => {
let mut cur = bytes;
let msg = <ShareFetchRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ShareFetchResponse" => {
let mut cur = bytes;
let msg = <ShareFetchResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_26(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"ShareGroupDescribeRequest" => {
let mut cur = bytes;
let msg =
<ShareGroupDescribeRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ShareGroupDescribeResponse" => {
let mut cur = bytes;
let msg =
<ShareGroupDescribeResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ShareGroupHeartbeatRequest" => {
let mut cur = bytes;
let msg =
<ShareGroupHeartbeatRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"ShareGroupHeartbeatResponse" => {
let mut cur = bytes;
let msg = <ShareGroupHeartbeatResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"StreamsGroupDescribeRequest" => {
let mut cur = bytes;
let msg = <StreamsGroupDescribeRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"StreamsGroupDescribeResponse" => {
let mut cur = bytes;
let msg = <StreamsGroupDescribeResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_27(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"StreamsGroupHeartbeatRequest" => {
let mut cur = bytes;
let msg = <StreamsGroupHeartbeatRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"StreamsGroupHeartbeatResponse" => {
let mut cur = bytes;
let msg = <StreamsGroupHeartbeatResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"StreamsGroupTopologyDescriptionUpdateRequest" => {
let mut cur = bytes;
let msg =
<StreamsGroupTopologyDescriptionUpdateRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"StreamsGroupTopologyDescriptionUpdateResponse" => {
let mut cur = bytes;
let msg =
<StreamsGroupTopologyDescriptionUpdateResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"SyncGroupRequest" => {
let mut cur = bytes;
let msg = <SyncGroupRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"SyncGroupResponse" => {
let mut cur = bytes;
let msg = <SyncGroupResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_28(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"TxnOffsetCommitRequest" => {
let mut cur = bytes;
let msg =
<TxnOffsetCommitRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"TxnOffsetCommitResponse" => {
let mut cur = bytes;
let msg =
<TxnOffsetCommitResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"UnregisterBrokerRequest" => {
let mut cur = bytes;
let msg =
<UnregisterBrokerRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"UnregisterBrokerResponse" => {
let mut cur = bytes;
let msg =
<UnregisterBrokerResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"UnregisterControllerRequest" => {
let mut cur = bytes;
let msg = <UnregisterControllerRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"UnregisterControllerResponse" => {
let mut cur = bytes;
let msg = <UnregisterControllerResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_29(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"UpdateFeaturesRequest" => {
let mut cur = bytes;
let msg =
<UpdateFeaturesRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"UpdateFeaturesResponse" => {
let mut cur = bytes;
let msg =
<UpdateFeaturesResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"UpdateRaftVoterRequest" => {
let mut cur = bytes;
let msg =
<UpdateRaftVoterRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"UpdateRaftVoterResponse" => {
let mut cur = bytes;
let msg = <owned::update_raft_voter_response::UpdateRaftVoterResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"VoteRequest" => {
let mut cur = bytes;
let msg = <VoteRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"VoteResponse" => {
let mut cur = bytes;
let msg = <owned::vote_response::VoteResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
fn roundtrip_30(name: &str, version: i16, bytes: &[u8]) -> Result<Option<Vec<u8>>, TableError> {
Ok(Some(match name {
"WriteShareGroupStateRequest" => {
let mut cur = bytes;
let msg = <WriteShareGroupStateRequest as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"WriteShareGroupStateResponse" => {
let mut cur = bytes;
let msg = <WriteShareGroupStateResponse as krabka_protocol::Decode>::decode(
&mut cur, version,
)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"WriteTxnMarkersRequest" => {
let mut cur = bytes;
let msg =
<WriteTxnMarkersRequest as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
"WriteTxnMarkersResponse" => {
let mut cur = bytes;
let msg =
<WriteTxnMarkersResponse as krabka_protocol::Decode>::decode(&mut cur, version)?;
expect_consumed(name, cur)?;
encode_with(&msg, version)?
}
_ => return Ok(None),
}))
}
pub fn roundtrip(name: &str, version: i16, bytes: &[u8]) -> Result<Vec<u8>, TableError> {
if let Some(value) = roundtrip_0(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_1(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_2(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_3(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_4(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_5(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_6(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_7(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_8(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_9(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_10(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_11(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_12(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_13(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_14(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_15(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_16(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_17(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_18(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_19(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_20(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_21(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_22(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_23(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_24(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_25(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_26(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_27(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_28(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_29(name, version, bytes)? {
return Ok(value);
}
if let Some(value) = roundtrip_30(name, version, bytes)? {
return Ok(value);
}
Err(TableError::UnknownMessage(name.to_owned()))
}
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) -> Result<i16, TableError> {
table
.iter()
.find_map(|(candidate, minimum)| (*candidate == name).then_some(*minimum))
.ok_or_else(|| TableError::UnknownMessage(name.to_owned()))
}
pub fn request_header_version(name: &str, version: i16) -> Result<i16, TableError> {
if name == "ControlledShutdownRequest" && version == 0 {
return Ok(0);
}
let minimum = header_flex_min(REQUEST_FLEX_MIN, name)?;
Ok(if minimum == i16::MIN || version >= minimum {
2
} else {
1
})
}
pub fn response_header_version(name: &str, version: i16) -> Result<i16, TableError> {
if name == "ApiVersionsResponse" {
return Ok(0);
}
let minimum = header_flex_min(RESPONSE_FLEX_MIN, name)?;
Ok(i16::from(minimum != i16::MIN && version >= minimum))
}
pub fn strip_frame_header(
name: &str,
version: i16,
is_request: bool,
frame: &[u8],
) -> Result<Vec<u8>, TableError> {
let mut cur = frame;
if is_request {
let hv = request_header_version(name, version)?;
<RequestHeader as krabka_protocol::Decode>::decode(&mut cur, hv)?;
} else {
let hv = response_header_version(name, version)?;
<ResponseHeader as krabka_protocol::Decode>::decode(&mut cur, hv)?;
}
Ok(cur.to_vec())
}