Enum kafka_protocol::messages::ResponseKind

#[non_exhaustive]
pub enum ResponseKind {
    ProduceResponse(ProduceResponse),
    FetchResponse(FetchResponse),
    ListOffsetsResponse(ListOffsetsResponse),
    MetadataResponse(MetadataResponse),
    LeaderAndIsrResponse(LeaderAndIsrResponse),
    StopReplicaResponse(StopReplicaResponse),
    UpdateMetadataResponse(UpdateMetadataResponse),
    ControlledShutdownResponse(ControlledShutdownResponse),
    OffsetCommitResponse(OffsetCommitResponse),
    OffsetFetchResponse(OffsetFetchResponse),
    FindCoordinatorResponse(FindCoordinatorResponse),
    JoinGroupResponse(JoinGroupResponse),
    HeartbeatResponse(HeartbeatResponse),
    LeaveGroupResponse(LeaveGroupResponse),
    SyncGroupResponse(SyncGroupResponse),
    DescribeGroupsResponse(DescribeGroupsResponse),
    ListGroupsResponse(ListGroupsResponse),
    SaslHandshakeResponse(SaslHandshakeResponse),
    ApiVersionsResponse(ApiVersionsResponse),
    CreateTopicsResponse(CreateTopicsResponse),
    DeleteTopicsResponse(DeleteTopicsResponse),
    DeleteRecordsResponse(DeleteRecordsResponse),
    InitProducerIdResponse(InitProducerIdResponse),
    OffsetForLeaderEpochResponse(OffsetForLeaderEpochResponse),
    AddPartitionsToTxnResponse(AddPartitionsToTxnResponse),
    AddOffsetsToTxnResponse(AddOffsetsToTxnResponse),
    EndTxnResponse(EndTxnResponse),
    WriteTxnMarkersResponse(WriteTxnMarkersResponse),
    TxnOffsetCommitResponse(TxnOffsetCommitResponse),
    DescribeAclsResponse(DescribeAclsResponse),
    CreateAclsResponse(CreateAclsResponse),
    DeleteAclsResponse(DeleteAclsResponse),
    DescribeConfigsResponse(DescribeConfigsResponse),
    AlterConfigsResponse(AlterConfigsResponse),
    AlterReplicaLogDirsResponse(AlterReplicaLogDirsResponse),
    DescribeLogDirsResponse(DescribeLogDirsResponse),
    SaslAuthenticateResponse(SaslAuthenticateResponse),
    CreatePartitionsResponse(CreatePartitionsResponse),
    CreateDelegationTokenResponse(CreateDelegationTokenResponse),
    RenewDelegationTokenResponse(RenewDelegationTokenResponse),
    ExpireDelegationTokenResponse(ExpireDelegationTokenResponse),
    DescribeDelegationTokenResponse(DescribeDelegationTokenResponse),
    DeleteGroupsResponse(DeleteGroupsResponse),
    ElectLeadersResponse(ElectLeadersResponse),
    IncrementalAlterConfigsResponse(IncrementalAlterConfigsResponse),
    AlterPartitionReassignmentsResponse(AlterPartitionReassignmentsResponse),
    ListPartitionReassignmentsResponse(ListPartitionReassignmentsResponse),
    OffsetDeleteResponse(OffsetDeleteResponse),
    DescribeClientQuotasResponse(DescribeClientQuotasResponse),
    AlterClientQuotasResponse(AlterClientQuotasResponse),
    DescribeUserScramCredentialsResponse(DescribeUserScramCredentialsResponse),
    AlterUserScramCredentialsResponse(AlterUserScramCredentialsResponse),
    VoteResponse(VoteResponse),
    BeginQuorumEpochResponse(BeginQuorumEpochResponse),
    EndQuorumEpochResponse(EndQuorumEpochResponse),
    DescribeQuorumResponse(DescribeQuorumResponse),
    AlterPartitionResponse(AlterPartitionResponse),
    UpdateFeaturesResponse(UpdateFeaturesResponse),
    EnvelopeResponse(EnvelopeResponse),
    FetchSnapshotResponse(FetchSnapshotResponse),
    DescribeClusterResponse(DescribeClusterResponse),
    DescribeProducersResponse(DescribeProducersResponse),
    BrokerRegistrationResponse(BrokerRegistrationResponse),
    BrokerHeartbeatResponse(BrokerHeartbeatResponse),
    UnregisterBrokerResponse(UnregisterBrokerResponse),
    DescribeTransactionsResponse(DescribeTransactionsResponse),
    ListTransactionsResponse(ListTransactionsResponse),
    AllocateProducerIdsResponse(AllocateProducerIdsResponse),
    ConsumerGroupHeartbeatResponse(ConsumerGroupHeartbeatResponse),
    ControllerRegistrationResponse(ControllerRegistrationResponse),
    GetTelemetrySubscriptionsResponse(GetTelemetrySubscriptionsResponse),
    PushTelemetryResponse(PushTelemetryResponse),
    AssignReplicasToDirsResponse(AssignReplicasToDirsResponse),
    ListClientMetricsResourcesResponse(ListClientMetricsResourcesResponse),
}

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.

ProduceResponse(ProduceResponse)

ProduceResponse,

FetchResponse(FetchResponse)

FetchResponse,

ListOffsetsResponse(ListOffsetsResponse)

ListOffsetsResponse,

MetadataResponse(MetadataResponse)

MetadataResponse,

LeaderAndIsrResponse(LeaderAndIsrResponse)

LeaderAndIsrResponse,

StopReplicaResponse(StopReplicaResponse)

StopReplicaResponse,

UpdateMetadataResponse(UpdateMetadataResponse)

UpdateMetadataResponse,

ControlledShutdownResponse(ControlledShutdownResponse)

ControlledShutdownResponse,

OffsetCommitResponse(OffsetCommitResponse)

OffsetCommitResponse,

OffsetFetchResponse(OffsetFetchResponse)

OffsetFetchResponse,

FindCoordinatorResponse(FindCoordinatorResponse)

FindCoordinatorResponse,

JoinGroupResponse(JoinGroupResponse)

JoinGroupResponse,

HeartbeatResponse(HeartbeatResponse)

HeartbeatResponse,

LeaveGroupResponse(LeaveGroupResponse)

LeaveGroupResponse,

SyncGroupResponse(SyncGroupResponse)

SyncGroupResponse,

DescribeGroupsResponse(DescribeGroupsResponse)

DescribeGroupsResponse,

ListGroupsResponse(ListGroupsResponse)

ListGroupsResponse,

SaslHandshakeResponse(SaslHandshakeResponse)

SaslHandshakeResponse,

ApiVersionsResponse(ApiVersionsResponse)

ApiVersionsResponse,

CreateTopicsResponse(CreateTopicsResponse)

CreateTopicsResponse,

DeleteTopicsResponse(DeleteTopicsResponse)

DeleteTopicsResponse,

DeleteRecordsResponse(DeleteRecordsResponse)

DeleteRecordsResponse,

InitProducerIdResponse(InitProducerIdResponse)

InitProducerIdResponse,

OffsetForLeaderEpochResponse(OffsetForLeaderEpochResponse)

OffsetForLeaderEpochResponse,

AddPartitionsToTxnResponse(AddPartitionsToTxnResponse)

AddPartitionsToTxnResponse,

AddOffsetsToTxnResponse(AddOffsetsToTxnResponse)

AddOffsetsToTxnResponse,

EndTxnResponse(EndTxnResponse)

EndTxnResponse,

WriteTxnMarkersResponse(WriteTxnMarkersResponse)

WriteTxnMarkersResponse,

TxnOffsetCommitResponse(TxnOffsetCommitResponse)

TxnOffsetCommitResponse,

DescribeAclsResponse(DescribeAclsResponse)

DescribeAclsResponse,

CreateAclsResponse(CreateAclsResponse)

CreateAclsResponse,

DeleteAclsResponse(DeleteAclsResponse)

DeleteAclsResponse,

DescribeConfigsResponse(DescribeConfigsResponse)

DescribeConfigsResponse,

AlterConfigsResponse(AlterConfigsResponse)

AlterConfigsResponse,

AlterReplicaLogDirsResponse(AlterReplicaLogDirsResponse)

AlterReplicaLogDirsResponse,

DescribeLogDirsResponse(DescribeLogDirsResponse)

DescribeLogDirsResponse,

SaslAuthenticateResponse(SaslAuthenticateResponse)

SaslAuthenticateResponse,

CreatePartitionsResponse(CreatePartitionsResponse)

CreatePartitionsResponse,

CreateDelegationTokenResponse(CreateDelegationTokenResponse)

CreateDelegationTokenResponse,

RenewDelegationTokenResponse(RenewDelegationTokenResponse)

RenewDelegationTokenResponse,

ExpireDelegationTokenResponse(ExpireDelegationTokenResponse)

ExpireDelegationTokenResponse,

DescribeDelegationTokenResponse(DescribeDelegationTokenResponse)

DescribeDelegationTokenResponse,

DeleteGroupsResponse(DeleteGroupsResponse)

DeleteGroupsResponse,

ElectLeadersResponse(ElectLeadersResponse)

ElectLeadersResponse,

IncrementalAlterConfigsResponse(IncrementalAlterConfigsResponse)

IncrementalAlterConfigsResponse,

AlterPartitionReassignmentsResponse(AlterPartitionReassignmentsResponse)

AlterPartitionReassignmentsResponse,

ListPartitionReassignmentsResponse(ListPartitionReassignmentsResponse)

ListPartitionReassignmentsResponse,

OffsetDeleteResponse(OffsetDeleteResponse)

OffsetDeleteResponse,

DescribeClientQuotasResponse(DescribeClientQuotasResponse)

DescribeClientQuotasResponse,

AlterClientQuotasResponse(AlterClientQuotasResponse)

AlterClientQuotasResponse,

DescribeUserScramCredentialsResponse(DescribeUserScramCredentialsResponse)

DescribeUserScramCredentialsResponse,

AlterUserScramCredentialsResponse(AlterUserScramCredentialsResponse)

AlterUserScramCredentialsResponse,

VoteResponse(VoteResponse)

VoteResponse,

BeginQuorumEpochResponse(BeginQuorumEpochResponse)

BeginQuorumEpochResponse,

EndQuorumEpochResponse(EndQuorumEpochResponse)

EndQuorumEpochResponse,

DescribeQuorumResponse(DescribeQuorumResponse)

DescribeQuorumResponse,

AlterPartitionResponse(AlterPartitionResponse)

AlterPartitionResponse,

UpdateFeaturesResponse(UpdateFeaturesResponse)

UpdateFeaturesResponse,

EnvelopeResponse(EnvelopeResponse)

EnvelopeResponse,

FetchSnapshotResponse(FetchSnapshotResponse)

FetchSnapshotResponse,

DescribeClusterResponse(DescribeClusterResponse)

DescribeClusterResponse,

DescribeProducersResponse(DescribeProducersResponse)

DescribeProducersResponse,

BrokerRegistrationResponse(BrokerRegistrationResponse)

BrokerRegistrationResponse,

BrokerHeartbeatResponse(BrokerHeartbeatResponse)

BrokerHeartbeatResponse,

UnregisterBrokerResponse(UnregisterBrokerResponse)

UnregisterBrokerResponse,

DescribeTransactionsResponse(DescribeTransactionsResponse)

DescribeTransactionsResponse,

ListTransactionsResponse(ListTransactionsResponse)

ListTransactionsResponse,

AllocateProducerIdsResponse(AllocateProducerIdsResponse)

AllocateProducerIdsResponse,

ConsumerGroupHeartbeatResponse(ConsumerGroupHeartbeatResponse)

ConsumerGroupHeartbeatResponse,

ControllerRegistrationResponse(ControllerRegistrationResponse)

ControllerRegistrationResponse,

GetTelemetrySubscriptionsResponse(GetTelemetrySubscriptionsResponse)

GetTelemetrySubscriptionsResponse,

PushTelemetryResponse(PushTelemetryResponse)

PushTelemetryResponse,

AssignReplicasToDirsResponse(AssignReplicasToDirsResponse)

AssignReplicasToDirsResponse,

ListClientMetricsResourcesResponse(ListClientMetricsResourcesResponse)

ListClientMetricsResourcesResponse,

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl StructuralPartialEq for ResponseKind