Enum kafka_protocol::messages::ResponseKind

source · [−]

pub enum ResponseKind {
Show 68 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),
    AlterIsrResponse(AlterIsrResponse),
    UpdateFeaturesResponse(UpdateFeaturesResponse),
    EnvelopeResponse(EnvelopeResponse),
    FetchSnapshotResponse(FetchSnapshotResponse),
    DescribeClusterResponse(DescribeClusterResponse),
    DescribeProducersResponse(DescribeProducersResponse),
    BrokerRegistrationResponse(BrokerRegistrationResponse),
    BrokerHeartbeatResponse(BrokerHeartbeatResponse),
    UnregisterBrokerResponse(UnregisterBrokerResponse),
    DescribeTransactionsResponse(DescribeTransactionsResponse),
    ListTransactionsResponse(ListTransactionsResponse),
    AllocateProducerIdsResponse(AllocateProducerIdsResponse),
}

Expand description

Wrapping enum for all responses in the Kafka protocol.

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,

`AlterIsrResponse(AlterIsrResponse)`

AlterIsrResponse,

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

Trait Implementations

source

impl Debug for ResponseKind

source

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

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl RefUnwindSafe for ResponseKind

impl Send for ResponseKind

impl Sync for ResponseKind

impl Unpin for ResponseKind

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, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · 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.

const: unstable · source

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

Performs the conversion.