#[non_exhaustive]pub enum ResponseKind {
Show 79 variants
Produce(ProduceResponse),
Fetch(FetchResponse),
ListOffsets(ListOffsetsResponse),
Metadata(MetadataResponse),
LeaderAndIsr(LeaderAndIsrResponse),
StopReplica(StopReplicaResponse),
UpdateMetadata(UpdateMetadataResponse),
ControlledShutdown(ControlledShutdownResponse),
OffsetCommit(OffsetCommitResponse),
OffsetFetch(OffsetFetchResponse),
FindCoordinator(FindCoordinatorResponse),
JoinGroup(JoinGroupResponse),
Heartbeat(HeartbeatResponse),
LeaveGroup(LeaveGroupResponse),
SyncGroup(SyncGroupResponse),
DescribeGroups(DescribeGroupsResponse),
ListGroups(ListGroupsResponse),
SaslHandshake(SaslHandshakeResponse),
ApiVersions(ApiVersionsResponse),
CreateTopics(CreateTopicsResponse),
DeleteTopics(DeleteTopicsResponse),
DeleteRecords(DeleteRecordsResponse),
InitProducerId(InitProducerIdResponse),
OffsetForLeaderEpoch(OffsetForLeaderEpochResponse),
AddPartitionsToTxn(AddPartitionsToTxnResponse),
AddOffsetsToTxn(AddOffsetsToTxnResponse),
EndTxn(EndTxnResponse),
WriteTxnMarkers(WriteTxnMarkersResponse),
TxnOffsetCommit(TxnOffsetCommitResponse),
DescribeAcls(DescribeAclsResponse),
CreateAcls(CreateAclsResponse),
DeleteAcls(DeleteAclsResponse),
DescribeConfigs(DescribeConfigsResponse),
AlterConfigs(AlterConfigsResponse),
AlterReplicaLogDirs(AlterReplicaLogDirsResponse),
DescribeLogDirs(DescribeLogDirsResponse),
SaslAuthenticate(SaslAuthenticateResponse),
CreatePartitions(CreatePartitionsResponse),
CreateDelegationToken(CreateDelegationTokenResponse),
RenewDelegationToken(RenewDelegationTokenResponse),
ExpireDelegationToken(ExpireDelegationTokenResponse),
DescribeDelegationToken(DescribeDelegationTokenResponse),
DeleteGroups(DeleteGroupsResponse),
ElectLeaders(ElectLeadersResponse),
IncrementalAlterConfigs(IncrementalAlterConfigsResponse),
AlterPartitionReassignments(AlterPartitionReassignmentsResponse),
ListPartitionReassignments(ListPartitionReassignmentsResponse),
OffsetDelete(OffsetDeleteResponse),
DescribeClientQuotas(DescribeClientQuotasResponse),
AlterClientQuotas(AlterClientQuotasResponse),
DescribeUserScramCredentials(DescribeUserScramCredentialsResponse),
AlterUserScramCredentials(AlterUserScramCredentialsResponse),
Vote(VoteResponse),
BeginQuorumEpoch(BeginQuorumEpochResponse),
EndQuorumEpoch(EndQuorumEpochResponse),
DescribeQuorum(DescribeQuorumResponse),
AlterPartition(AlterPartitionResponse),
UpdateFeatures(UpdateFeaturesResponse),
Envelope(EnvelopeResponse),
FetchSnapshot(FetchSnapshotResponse),
DescribeCluster(DescribeClusterResponse),
DescribeProducers(DescribeProducersResponse),
BrokerRegistration(BrokerRegistrationResponse),
BrokerHeartbeat(BrokerHeartbeatResponse),
UnregisterBroker(UnregisterBrokerResponse),
DescribeTransactions(DescribeTransactionsResponse),
ListTransactions(ListTransactionsResponse),
AllocateProducerIds(AllocateProducerIdsResponse),
ConsumerGroupHeartbeat(ConsumerGroupHeartbeatResponse),
ConsumerGroupDescribe(ConsumerGroupDescribeResponse),
ControllerRegistration(ControllerRegistrationResponse),
GetTelemetrySubscriptions(GetTelemetrySubscriptionsResponse),
PushTelemetry(PushTelemetryResponse),
AssignReplicasToDirs(AssignReplicasToDirsResponse),
ListClientMetricsResources(ListClientMetricsResourcesResponse),
DescribeTopicPartitions(DescribeTopicPartitionsResponse),
AddRaftVoter(AddRaftVoterResponse),
RemoveRaftVoter(RemoveRaftVoterResponse),
UpdateRaftVoter(UpdateRaftVoterResponse),
}
messages_enums
only.Expand description
Wrapping enum for all responses in the Kafka protocol.
Variants (Non-exhaustive)§
This enum is marked as non-exhaustive
Produce(ProduceResponse)
ProduceResponse,
Fetch(FetchResponse)
FetchResponse,
ListOffsets(ListOffsetsResponse)
ListOffsetsResponse,
Metadata(MetadataResponse)
MetadataResponse,
LeaderAndIsr(LeaderAndIsrResponse)
LeaderAndIsrResponse,
StopReplica(StopReplicaResponse)
StopReplicaResponse,
UpdateMetadata(UpdateMetadataResponse)
UpdateMetadataResponse,
ControlledShutdown(ControlledShutdownResponse)
ControlledShutdownResponse,
OffsetCommit(OffsetCommitResponse)
OffsetCommitResponse,
OffsetFetch(OffsetFetchResponse)
OffsetFetchResponse,
FindCoordinator(FindCoordinatorResponse)
FindCoordinatorResponse,
JoinGroup(JoinGroupResponse)
JoinGroupResponse,
Heartbeat(HeartbeatResponse)
HeartbeatResponse,
LeaveGroup(LeaveGroupResponse)
LeaveGroupResponse,
SyncGroup(SyncGroupResponse)
SyncGroupResponse,
DescribeGroups(DescribeGroupsResponse)
DescribeGroupsResponse,
ListGroups(ListGroupsResponse)
ListGroupsResponse,
SaslHandshake(SaslHandshakeResponse)
SaslHandshakeResponse,
ApiVersions(ApiVersionsResponse)
ApiVersionsResponse,
CreateTopics(CreateTopicsResponse)
CreateTopicsResponse,
DeleteTopics(DeleteTopicsResponse)
DeleteTopicsResponse,
DeleteRecords(DeleteRecordsResponse)
DeleteRecordsResponse,
InitProducerId(InitProducerIdResponse)
InitProducerIdResponse,
OffsetForLeaderEpoch(OffsetForLeaderEpochResponse)
OffsetForLeaderEpochResponse,
AddPartitionsToTxn(AddPartitionsToTxnResponse)
AddPartitionsToTxnResponse,
AddOffsetsToTxn(AddOffsetsToTxnResponse)
AddOffsetsToTxnResponse,
EndTxn(EndTxnResponse)
EndTxnResponse,
WriteTxnMarkers(WriteTxnMarkersResponse)
WriteTxnMarkersResponse,
TxnOffsetCommit(TxnOffsetCommitResponse)
TxnOffsetCommitResponse,
DescribeAcls(DescribeAclsResponse)
DescribeAclsResponse,
CreateAcls(CreateAclsResponse)
CreateAclsResponse,
DeleteAcls(DeleteAclsResponse)
DeleteAclsResponse,
DescribeConfigs(DescribeConfigsResponse)
DescribeConfigsResponse,
AlterConfigs(AlterConfigsResponse)
AlterConfigsResponse,
AlterReplicaLogDirs(AlterReplicaLogDirsResponse)
AlterReplicaLogDirsResponse,
DescribeLogDirs(DescribeLogDirsResponse)
DescribeLogDirsResponse,
SaslAuthenticate(SaslAuthenticateResponse)
SaslAuthenticateResponse,
CreatePartitions(CreatePartitionsResponse)
CreatePartitionsResponse,
CreateDelegationToken(CreateDelegationTokenResponse)
CreateDelegationTokenResponse,
RenewDelegationToken(RenewDelegationTokenResponse)
RenewDelegationTokenResponse,
ExpireDelegationToken(ExpireDelegationTokenResponse)
ExpireDelegationTokenResponse,
DescribeDelegationToken(DescribeDelegationTokenResponse)
DescribeDelegationTokenResponse,
DeleteGroups(DeleteGroupsResponse)
DeleteGroupsResponse,
ElectLeaders(ElectLeadersResponse)
ElectLeadersResponse,
IncrementalAlterConfigs(IncrementalAlterConfigsResponse)
IncrementalAlterConfigsResponse,
AlterPartitionReassignments(AlterPartitionReassignmentsResponse)
AlterPartitionReassignmentsResponse,
ListPartitionReassignments(ListPartitionReassignmentsResponse)
ListPartitionReassignmentsResponse,
OffsetDelete(OffsetDeleteResponse)
OffsetDeleteResponse,
DescribeClientQuotas(DescribeClientQuotasResponse)
DescribeClientQuotasResponse,
AlterClientQuotas(AlterClientQuotasResponse)
AlterClientQuotasResponse,
DescribeUserScramCredentials(DescribeUserScramCredentialsResponse)
DescribeUserScramCredentialsResponse,
AlterUserScramCredentials(AlterUserScramCredentialsResponse)
AlterUserScramCredentialsResponse,
Vote(VoteResponse)
VoteResponse,
BeginQuorumEpoch(BeginQuorumEpochResponse)
BeginQuorumEpochResponse,
EndQuorumEpoch(EndQuorumEpochResponse)
EndQuorumEpochResponse,
DescribeQuorum(DescribeQuorumResponse)
DescribeQuorumResponse,
AlterPartition(AlterPartitionResponse)
AlterPartitionResponse,
UpdateFeatures(UpdateFeaturesResponse)
UpdateFeaturesResponse,
Envelope(EnvelopeResponse)
EnvelopeResponse,
FetchSnapshot(FetchSnapshotResponse)
FetchSnapshotResponse,
DescribeCluster(DescribeClusterResponse)
DescribeClusterResponse,
DescribeProducers(DescribeProducersResponse)
DescribeProducersResponse,
BrokerRegistration(BrokerRegistrationResponse)
BrokerRegistrationResponse,
BrokerHeartbeat(BrokerHeartbeatResponse)
BrokerHeartbeatResponse,
UnregisterBroker(UnregisterBrokerResponse)
UnregisterBrokerResponse,
DescribeTransactions(DescribeTransactionsResponse)
DescribeTransactionsResponse,
ListTransactions(ListTransactionsResponse)
ListTransactionsResponse,
AllocateProducerIds(AllocateProducerIdsResponse)
AllocateProducerIdsResponse,
ConsumerGroupHeartbeat(ConsumerGroupHeartbeatResponse)
ConsumerGroupHeartbeatResponse,
ConsumerGroupDescribe(ConsumerGroupDescribeResponse)
ConsumerGroupDescribeResponse,
ControllerRegistration(ControllerRegistrationResponse)
ControllerRegistrationResponse,
GetTelemetrySubscriptions(GetTelemetrySubscriptionsResponse)
GetTelemetrySubscriptionsResponse,
PushTelemetry(PushTelemetryResponse)
PushTelemetryResponse,
AssignReplicasToDirs(AssignReplicasToDirsResponse)
AssignReplicasToDirsResponse,
ListClientMetricsResources(ListClientMetricsResourcesResponse)
ListClientMetricsResourcesResponse,
DescribeTopicPartitions(DescribeTopicPartitionsResponse)
DescribeTopicPartitionsResponse,
AddRaftVoter(AddRaftVoterResponse)
AddRaftVoterResponse,
RemoveRaftVoter(RemoveRaftVoterResponse)
RemoveRaftVoterResponse,
UpdateRaftVoter(UpdateRaftVoterResponse)
UpdateRaftVoterResponse,
Implementations§
Source§impl ResponseKind
impl ResponseKind
Sourcepub fn encode(&self, bytes: &mut BytesMut, version: i16) -> Result<()>
Available on crate feature broker
only.
pub fn encode(&self, bytes: &mut BytesMut, version: i16) -> Result<()>
broker
only.Encode the message into the target buffer
Sourcepub fn decode(
api_key: ApiKey,
bytes: &mut Bytes,
version: i16,
) -> Result<ResponseKind>
Available on crate feature client
only.
pub fn decode( api_key: ApiKey, bytes: &mut Bytes, version: i16, ) -> Result<ResponseKind>
client
only.Decode the message from the provided buffer and version
Sourcepub fn header_version(&self, version: i16) -> i16
pub fn header_version(&self, version: i16) -> i16
Get the version of request header that needs to be prepended to this message
Trait Implementations§
Source§impl Clone for ResponseKind
impl Clone for ResponseKind
Source§fn clone(&self) -> ResponseKind
fn clone(&self) -> ResponseKind
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read more