Enum ResponseKind

#[non_exhaustive]
pub enum ResponseKind {
    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),
}

Available on crate feature messages_enums only.

Wrapping enum for all responses in the Kafka protocol.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

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,

Implementations

impl ResponseKind

pub fn encode(&self, bytes: &mut BytesMut, version: i16) -> Result<()>

Available on crate feature broker only.

Encode the message into the target buffer

pub fn decode( api_key: ApiKey, bytes: &mut Bytes, version: i16, ) -> Result<ResponseKind>

Available on crate feature client only.

Decode the message from the provided buffer and version

pub fn header_version(&self, version: i16) -> i16

Get the version of request header that needs to be prepended to this message

Trait Implementations

impl Clone for ResponseKind

fn clone(&self) -> ResponseKind

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ResponseKind

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<AddOffsetsToTxnResponse> for ResponseKind

fn from(value: AddOffsetsToTxnResponse) -> ResponseKind

Converts to this type from the input type.

impl From<AddPartitionsToTxnResponse> for ResponseKind

fn from(value: AddPartitionsToTxnResponse) -> ResponseKind

Converts to this type from the input type.

impl From<AllocateProducerIdsResponse> for ResponseKind

fn from(value: AllocateProducerIdsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<AlterClientQuotasResponse> for ResponseKind

fn from(value: AlterClientQuotasResponse) -> ResponseKind

Converts to this type from the input type.

impl From<AlterConfigsResponse> for ResponseKind

fn from(value: AlterConfigsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<AlterPartitionReassignmentsResponse> for ResponseKind

fn from(value: AlterPartitionReassignmentsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<AlterPartitionResponse> for ResponseKind

fn from(value: AlterPartitionResponse) -> ResponseKind

Converts to this type from the input type.

impl From<AlterReplicaLogDirsResponse> for ResponseKind

fn from(value: AlterReplicaLogDirsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<AlterUserScramCredentialsResponse> for ResponseKind

fn from(value: AlterUserScramCredentialsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ApiVersionsResponse> for ResponseKind

fn from(value: ApiVersionsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<AssignReplicasToDirsResponse> for ResponseKind

fn from(value: AssignReplicasToDirsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<BeginQuorumEpochResponse> for ResponseKind

fn from(value: BeginQuorumEpochResponse) -> ResponseKind

Converts to this type from the input type.

impl From<BrokerHeartbeatResponse> for ResponseKind

fn from(value: BrokerHeartbeatResponse) -> ResponseKind

Converts to this type from the input type.

impl From<BrokerRegistrationResponse> for ResponseKind

fn from(value: BrokerRegistrationResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ConsumerGroupDescribeResponse> for ResponseKind

fn from(value: ConsumerGroupDescribeResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ConsumerGroupHeartbeatResponse> for ResponseKind

fn from(value: ConsumerGroupHeartbeatResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ControlledShutdownResponse> for ResponseKind

fn from(value: ControlledShutdownResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ControllerRegistrationResponse> for ResponseKind

fn from(value: ControllerRegistrationResponse) -> ResponseKind

Converts to this type from the input type.

impl From<CreateAclsResponse> for ResponseKind

fn from(value: CreateAclsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<CreateDelegationTokenResponse> for ResponseKind

fn from(value: CreateDelegationTokenResponse) -> ResponseKind

Converts to this type from the input type.

impl From<CreatePartitionsResponse> for ResponseKind

fn from(value: CreatePartitionsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<CreateTopicsResponse> for ResponseKind

fn from(value: CreateTopicsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DeleteAclsResponse> for ResponseKind

fn from(value: DeleteAclsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DeleteGroupsResponse> for ResponseKind

fn from(value: DeleteGroupsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DeleteRecordsResponse> for ResponseKind

fn from(value: DeleteRecordsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DeleteTopicsResponse> for ResponseKind

fn from(value: DeleteTopicsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeAclsResponse> for ResponseKind

fn from(value: DescribeAclsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeClientQuotasResponse> for ResponseKind

fn from(value: DescribeClientQuotasResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeClusterResponse> for ResponseKind

fn from(value: DescribeClusterResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeConfigsResponse> for ResponseKind

fn from(value: DescribeConfigsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeDelegationTokenResponse> for ResponseKind

fn from(value: DescribeDelegationTokenResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeGroupsResponse> for ResponseKind

fn from(value: DescribeGroupsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeLogDirsResponse> for ResponseKind

fn from(value: DescribeLogDirsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeProducersResponse> for ResponseKind

fn from(value: DescribeProducersResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeQuorumResponse> for ResponseKind

fn from(value: DescribeQuorumResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeTopicPartitionsResponse> for ResponseKind

fn from(value: DescribeTopicPartitionsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeTransactionsResponse> for ResponseKind

fn from(value: DescribeTransactionsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<DescribeUserScramCredentialsResponse> for ResponseKind

fn from(value: DescribeUserScramCredentialsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ElectLeadersResponse> for ResponseKind

fn from(value: ElectLeadersResponse) -> ResponseKind

Converts to this type from the input type.

impl From<EndQuorumEpochResponse> for ResponseKind

fn from(value: EndQuorumEpochResponse) -> ResponseKind

Converts to this type from the input type.

impl From<EndTxnResponse> for ResponseKind

fn from(value: EndTxnResponse) -> ResponseKind

Converts to this type from the input type.

impl From<EnvelopeResponse> for ResponseKind

fn from(value: EnvelopeResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ExpireDelegationTokenResponse> for ResponseKind

fn from(value: ExpireDelegationTokenResponse) -> ResponseKind

Converts to this type from the input type.

impl From<FetchResponse> for ResponseKind

fn from(value: FetchResponse) -> ResponseKind

Converts to this type from the input type.

impl From<FetchSnapshotResponse> for ResponseKind

fn from(value: FetchSnapshotResponse) -> ResponseKind

Converts to this type from the input type.

impl From<FindCoordinatorResponse> for ResponseKind

fn from(value: FindCoordinatorResponse) -> ResponseKind

Converts to this type from the input type.

impl From<GetTelemetrySubscriptionsResponse> for ResponseKind

fn from(value: GetTelemetrySubscriptionsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<HeartbeatResponse> for ResponseKind

fn from(value: HeartbeatResponse) -> ResponseKind

Converts to this type from the input type.

impl From<IncrementalAlterConfigsResponse> for ResponseKind

fn from(value: IncrementalAlterConfigsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<InitProducerIdResponse> for ResponseKind

fn from(value: InitProducerIdResponse) -> ResponseKind

Converts to this type from the input type.

impl From<JoinGroupResponse> for ResponseKind

fn from(value: JoinGroupResponse) -> ResponseKind

Converts to this type from the input type.

impl From<LeaderAndIsrResponse> for ResponseKind

fn from(value: LeaderAndIsrResponse) -> ResponseKind

Converts to this type from the input type.

impl From<LeaveGroupResponse> for ResponseKind

fn from(value: LeaveGroupResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ListClientMetricsResourcesResponse> for ResponseKind

fn from(value: ListClientMetricsResourcesResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ListGroupsResponse> for ResponseKind

fn from(value: ListGroupsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ListOffsetsResponse> for ResponseKind

fn from(value: ListOffsetsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ListPartitionReassignmentsResponse> for ResponseKind

fn from(value: ListPartitionReassignmentsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ListTransactionsResponse> for ResponseKind

fn from(value: ListTransactionsResponse) -> ResponseKind

Converts to this type from the input type.

impl From<MetadataResponse> for ResponseKind

fn from(value: MetadataResponse) -> ResponseKind

Converts to this type from the input type.

impl From<OffsetCommitResponse> for ResponseKind

fn from(value: OffsetCommitResponse) -> ResponseKind

Converts to this type from the input type.

impl From<OffsetDeleteResponse> for ResponseKind

fn from(value: OffsetDeleteResponse) -> ResponseKind

Converts to this type from the input type.

impl From<OffsetFetchResponse> for ResponseKind

fn from(value: OffsetFetchResponse) -> ResponseKind

Converts to this type from the input type.

impl From<OffsetForLeaderEpochResponse> for ResponseKind

fn from(value: OffsetForLeaderEpochResponse) -> ResponseKind

Converts to this type from the input type.

impl From<ProduceResponse> for ResponseKind

fn from(value: ProduceResponse) -> ResponseKind

Converts to this type from the input type.

impl From<PushTelemetryResponse> for ResponseKind

fn from(value: PushTelemetryResponse) -> ResponseKind

Converts to this type from the input type.

impl From<RenewDelegationTokenResponse> for ResponseKind

fn from(value: RenewDelegationTokenResponse) -> ResponseKind

Converts to this type from the input type.

impl From<SaslAuthenticateResponse> for ResponseKind

fn from(value: SaslAuthenticateResponse) -> ResponseKind

Converts to this type from the input type.

impl From<SaslHandshakeResponse> for ResponseKind

fn from(value: SaslHandshakeResponse) -> ResponseKind

Converts to this type from the input type.

impl From<StopReplicaResponse> for ResponseKind

fn from(value: StopReplicaResponse) -> ResponseKind

Converts to this type from the input type.

impl From<SyncGroupResponse> for ResponseKind

fn from(value: SyncGroupResponse) -> ResponseKind

Converts to this type from the input type.

impl From<TxnOffsetCommitResponse> for ResponseKind

fn from(value: TxnOffsetCommitResponse) -> ResponseKind

Converts to this type from the input type.

impl From<UnregisterBrokerResponse> for ResponseKind

fn from(value: UnregisterBrokerResponse) -> ResponseKind

Converts to this type from the input type.

impl From<UpdateFeaturesResponse> for ResponseKind

fn from(value: UpdateFeaturesResponse) -> ResponseKind

Converts to this type from the input type.

impl From<UpdateMetadataResponse> for ResponseKind

fn from(value: UpdateMetadataResponse) -> ResponseKind

Converts to this type from the input type.

impl From<VoteResponse> for ResponseKind

fn from(value: VoteResponse) -> ResponseKind

Converts to this type from the input type.

impl From<WriteTxnMarkersResponse> for ResponseKind

fn from(value: WriteTxnMarkersResponse) -> ResponseKind

Converts to this type from the input type.

impl PartialEq for ResponseKind

fn eq(&self, other: &ResponseKind) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ResponseKind