Enum kafka_protocol::messages::ResponseKind

source ·

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

Expand description

Wrapping enum for all responses in the Kafka protocol.

Variants (Non-exhaustive)§

This enum is marked as 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§

source §

impl Clone for ResponseKind

source §

fn clone(&self) -> ResponseKind

Returns a copy of the value. Read more

1.0.0 · source§

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

Performs copy-assignment from source. Read more

source §

impl Debug for ResponseKind

source §

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

Formats the value using the given formatter. Read more

source §

impl PartialEq for ResponseKind

source §

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

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

1.0.0 · source§

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.

source §

impl StructuralPartialEq for ResponseKind

Auto Trait Implementations§

§

impl UnwindSafe for ResponseKind

Blanket Implementations§

source §

impl<T> Any for T
where T: 'static + ?Sized,

source §

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source §

impl<T> Borrow<T> for T
where T: ?Sized,

source §

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source §

impl<T> BorrowMut<T> for T
where T: ?Sized,

source §

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source §

impl<T> From<T> for T

source §

fn from(t: T) -> T

Returns the argument unchanged.

source §

impl<T, U> Into for T
where U: From<T>,

source §

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source §

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.

source §

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

source §

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

source §

impl<T, U> TryFrom for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.

source §

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source §

impl<T, U> TryInto for T
where U: TryFrom<T>,

§

type Error = >::Error

The type returned in the event of a conversion error.

source §

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.