krabka-protocol-0.5.1
Platform
- x86_64-unknown-linux-gnu
Feature flags

docs.rs

Rust

krabka-protocol 0.5.1

Apache Kafka wire-protocol codec (4.3.0), with typed RecordBatch and zero-copy borrowed decode

Crate
Source
Builds
Feature flags

..
common
kafka_3_6_2
AccessControlEntryRecord.borrowed.rs
AccessControlEntryRecord.owned.rs
AddOffsetsToTxnRequest.borrowed.rs
AddOffsetsToTxnRequest.owned.rs
AddOffsetsToTxnResponse.borrowed.rs
AddOffsetsToTxnResponse.owned.rs
AddPartitionsToTxnRequest.borrowed.rs
AddPartitionsToTxnRequest.owned.rs
AddPartitionsToTxnResponse.borrowed.rs
AddPartitionsToTxnResponse.owned.rs
AddRaftVoterRequest.borrowed.rs
AddRaftVoterRequest.owned.rs
AddRaftVoterResponse.borrowed.rs
AddRaftVoterResponse.owned.rs
AllocateProducerIdsRequest.borrowed.rs
AllocateProducerIdsRequest.owned.rs
AllocateProducerIdsResponse.borrowed.rs
AllocateProducerIdsResponse.owned.rs
AlterClientQuotasRequest.borrowed.rs
AlterClientQuotasRequest.owned.rs
AlterClientQuotasResponse.borrowed.rs
AlterClientQuotasResponse.owned.rs
AlterConfigsRequest.borrowed.rs
AlterConfigsRequest.owned.rs
AlterConfigsResponse.borrowed.rs
AlterConfigsResponse.owned.rs
AlterPartitionReassignmentsRequest.borrowed.rs
AlterPartitionReassignmentsRequest.owned.rs
AlterPartitionReassignmentsResponse.borrowed.rs
AlterPartitionReassignmentsResponse.owned.rs
AlterPartitionRequest.borrowed.rs
AlterPartitionRequest.owned.rs
AlterPartitionResponse.borrowed.rs
AlterPartitionResponse.owned.rs
AlterReplicaLogDirsRequest.borrowed.rs
AlterReplicaLogDirsRequest.owned.rs
AlterReplicaLogDirsResponse.borrowed.rs
AlterReplicaLogDirsResponse.owned.rs
AlterShareGroupOffsetsRequest.borrowed.rs
AlterShareGroupOffsetsRequest.owned.rs
AlterShareGroupOffsetsResponse.borrowed.rs
AlterShareGroupOffsetsResponse.owned.rs
AlterUserScramCredentialsRequest.borrowed.rs
AlterUserScramCredentialsRequest.owned.rs
AlterUserScramCredentialsResponse.borrowed.rs
AlterUserScramCredentialsResponse.owned.rs
api_key.rs
ApiVersionsRequest.borrowed.rs
ApiVersionsRequest.owned.rs
ApiVersionsResponse.borrowed.rs
ApiVersionsResponse.owned.rs
AssignReplicasToDirsRequest.borrowed.rs
AssignReplicasToDirsRequest.owned.rs
AssignReplicasToDirsResponse.borrowed.rs
AssignReplicasToDirsResponse.owned.rs
BeginQuorumEpochRequest.borrowed.rs
BeginQuorumEpochRequest.owned.rs
BeginQuorumEpochResponse.borrowed.rs
BeginQuorumEpochResponse.owned.rs
BeginTransactionRecord.borrowed.rs
BeginTransactionRecord.owned.rs
BrokerHeartbeatRequest.borrowed.rs
BrokerHeartbeatRequest.owned.rs
BrokerHeartbeatResponse.borrowed.rs
BrokerHeartbeatResponse.owned.rs
BrokerRegistrationChangeRecord.borrowed.rs
BrokerRegistrationChangeRecord.owned.rs
BrokerRegistrationRequest.borrowed.rs
BrokerRegistrationRequest.owned.rs
BrokerRegistrationResponse.borrowed.rs
BrokerRegistrationResponse.owned.rs
ClientQuotaRecord.borrowed.rs
ClientQuotaRecord.owned.rs
ConfigRecord.borrowed.rs
ConfigRecord.owned.rs
ConsumerGroupDescribeRequest.borrowed.rs
ConsumerGroupDescribeRequest.owned.rs
ConsumerGroupDescribeResponse.borrowed.rs
ConsumerGroupDescribeResponse.owned.rs
ConsumerGroupHeartbeatRequest.borrowed.rs
ConsumerGroupHeartbeatRequest.owned.rs
ConsumerGroupHeartbeatResponse.borrowed.rs
ConsumerGroupHeartbeatResponse.owned.rs
ConsumerProtocolAssignment.borrowed.rs
ConsumerProtocolAssignment.owned.rs
ConsumerProtocolSubscription.borrowed.rs
ConsumerProtocolSubscription.owned.rs
ControllerRegistrationRequest.borrowed.rs
ControllerRegistrationRequest.owned.rs
ControllerRegistrationResponse.borrowed.rs
ControllerRegistrationResponse.owned.rs
ControlRecordTypeSchema.borrowed.rs
ControlRecordTypeSchema.owned.rs
CreateAclsRequest.borrowed.rs
CreateAclsRequest.owned.rs
CreateAclsResponse.borrowed.rs
CreateAclsResponse.owned.rs
CreateDelegationTokenRequest.borrowed.rs
CreateDelegationTokenRequest.owned.rs
CreateDelegationTokenResponse.borrowed.rs
CreateDelegationTokenResponse.owned.rs
CreatePartitionsRequest.borrowed.rs
CreatePartitionsRequest.owned.rs
CreatePartitionsResponse.borrowed.rs
CreatePartitionsResponse.owned.rs
CreateTopicsRequest.borrowed.rs
CreateTopicsRequest.owned.rs
CreateTopicsResponse.borrowed.rs
CreateTopicsResponse.owned.rs
DefaultPrincipalData.borrowed.rs
DefaultPrincipalData.owned.rs
DelegationTokenRecord.borrowed.rs
DelegationTokenRecord.owned.rs
DeleteAclsRequest.borrowed.rs
DeleteAclsRequest.owned.rs
DeleteAclsResponse.borrowed.rs
DeleteAclsResponse.owned.rs
DeleteGroupsRequest.borrowed.rs
DeleteGroupsRequest.owned.rs
DeleteGroupsResponse.borrowed.rs
DeleteGroupsResponse.owned.rs
DeleteRecordsRequest.borrowed.rs
DeleteRecordsRequest.owned.rs
DeleteRecordsResponse.borrowed.rs
DeleteRecordsResponse.owned.rs
DeleteShareGroupOffsetsRequest.borrowed.rs
DeleteShareGroupOffsetsRequest.owned.rs
DeleteShareGroupOffsetsResponse.borrowed.rs
DeleteShareGroupOffsetsResponse.owned.rs
DeleteShareGroupStateRequest.borrowed.rs
DeleteShareGroupStateRequest.owned.rs
DeleteShareGroupStateResponse.borrowed.rs
DeleteShareGroupStateResponse.owned.rs
DeleteTopicsRequest.borrowed.rs
DeleteTopicsRequest.owned.rs
DeleteTopicsResponse.borrowed.rs
DeleteTopicsResponse.owned.rs
DescribeAclsRequest.borrowed.rs
DescribeAclsRequest.owned.rs
DescribeAclsResponse.borrowed.rs
DescribeAclsResponse.owned.rs
DescribeClientQuotasRequest.borrowed.rs
DescribeClientQuotasRequest.owned.rs
DescribeClientQuotasResponse.borrowed.rs
DescribeClientQuotasResponse.owned.rs
DescribeClusterRequest.borrowed.rs
DescribeClusterRequest.owned.rs
DescribeClusterResponse.borrowed.rs
DescribeClusterResponse.owned.rs
DescribeConfigsRequest.borrowed.rs
DescribeConfigsRequest.owned.rs
DescribeConfigsResponse.borrowed.rs
DescribeConfigsResponse.owned.rs
DescribeDelegationTokenRequest.borrowed.rs
DescribeDelegationTokenRequest.owned.rs
DescribeDelegationTokenResponse.borrowed.rs
DescribeDelegationTokenResponse.owned.rs
DescribeGroupsRequest.borrowed.rs
DescribeGroupsRequest.owned.rs
DescribeGroupsResponse.borrowed.rs
DescribeGroupsResponse.owned.rs
DescribeLogDirsRequest.borrowed.rs
DescribeLogDirsRequest.owned.rs
DescribeLogDirsResponse.borrowed.rs
DescribeLogDirsResponse.owned.rs
DescribeProducersRequest.borrowed.rs
DescribeProducersRequest.owned.rs
DescribeProducersResponse.borrowed.rs
DescribeProducersResponse.owned.rs
DescribeQuorumRequest.borrowed.rs
DescribeQuorumRequest.owned.rs
DescribeQuorumResponse.borrowed.rs
DescribeQuorumResponse.owned.rs
DescribeShareGroupOffsetsRequest.borrowed.rs
DescribeShareGroupOffsetsRequest.owned.rs
DescribeShareGroupOffsetsResponse.borrowed.rs
DescribeShareGroupOffsetsResponse.owned.rs
DescribeTopicPartitionsRequest.borrowed.rs
DescribeTopicPartitionsRequest.owned.rs
DescribeTopicPartitionsResponse.borrowed.rs
DescribeTopicPartitionsResponse.owned.rs
DescribeTransactionsRequest.borrowed.rs
DescribeTransactionsRequest.owned.rs
DescribeTransactionsResponse.borrowed.rs
DescribeTransactionsResponse.owned.rs
DescribeUserScramCredentialsRequest.borrowed.rs
DescribeUserScramCredentialsRequest.owned.rs
DescribeUserScramCredentialsResponse.borrowed.rs
DescribeUserScramCredentialsResponse.owned.rs
differential_table.rs
ElectLeadersRequest.borrowed.rs
ElectLeadersRequest.owned.rs
ElectLeadersResponse.borrowed.rs
ElectLeadersResponse.owned.rs
EndQuorumEpochRequest.borrowed.rs
EndQuorumEpochRequest.owned.rs
EndQuorumEpochResponse.borrowed.rs
EndQuorumEpochResponse.owned.rs
EndTransactionRecord.borrowed.rs
EndTransactionRecord.owned.rs
EndTxnMarker.borrowed.rs
EndTxnMarker.owned.rs
EndTxnRequest.borrowed.rs
EndTxnRequest.owned.rs
EndTxnResponse.borrowed.rs
EndTxnResponse.owned.rs
EnvelopeRequest.borrowed.rs
EnvelopeRequest.owned.rs
EnvelopeResponse.borrowed.rs
EnvelopeResponse.owned.rs
ExpireDelegationTokenRequest.borrowed.rs
ExpireDelegationTokenRequest.owned.rs
ExpireDelegationTokenResponse.borrowed.rs
ExpireDelegationTokenResponse.owned.rs
FeatureLevelRecord.borrowed.rs
FeatureLevelRecord.owned.rs
FetchRequest.borrowed.rs
FetchRequest.owned.rs
FetchResponse.borrowed.rs
FetchResponse.owned.rs
FetchSnapshotRequest.borrowed.rs
FetchSnapshotRequest.owned.rs
FetchSnapshotResponse.borrowed.rs
FetchSnapshotResponse.owned.rs
FindCoordinatorRequest.borrowed.rs
FindCoordinatorRequest.owned.rs
FindCoordinatorResponse.borrowed.rs
FindCoordinatorResponse.owned.rs
GetReplicaLogInfoRequest.borrowed.rs
GetReplicaLogInfoRequest.owned.rs
GetReplicaLogInfoResponse.borrowed.rs
GetReplicaLogInfoResponse.owned.rs
GetTelemetrySubscriptionsRequest.borrowed.rs
GetTelemetrySubscriptionsRequest.owned.rs
GetTelemetrySubscriptionsResponse.borrowed.rs
GetTelemetrySubscriptionsResponse.owned.rs
HeartbeatRequest.borrowed.rs
HeartbeatRequest.owned.rs
HeartbeatResponse.borrowed.rs
HeartbeatResponse.owned.rs
IncrementalAlterConfigsRequest.borrowed.rs
IncrementalAlterConfigsRequest.owned.rs
IncrementalAlterConfigsResponse.borrowed.rs
IncrementalAlterConfigsResponse.owned.rs
InitializeShareGroupStateRequest.borrowed.rs
InitializeShareGroupStateRequest.owned.rs
InitializeShareGroupStateResponse.borrowed.rs
InitializeShareGroupStateResponse.owned.rs
InitProducerIdRequest.borrowed.rs
InitProducerIdRequest.owned.rs
InitProducerIdResponse.borrowed.rs
InitProducerIdResponse.owned.rs
JoinGroupRequest.borrowed.rs
JoinGroupRequest.owned.rs
JoinGroupResponse.borrowed.rs
JoinGroupResponse.owned.rs
KRaftVersionRecord.borrowed.rs
KRaftVersionRecord.owned.rs
LeaderChangeMessage.borrowed.rs
LeaderChangeMessage.owned.rs
LeaveGroupRequest.borrowed.rs
LeaveGroupRequest.owned.rs
LeaveGroupResponse.borrowed.rs
LeaveGroupResponse.owned.rs
ListConfigResourcesRequest.borrowed.rs
ListConfigResourcesRequest.owned.rs
ListConfigResourcesResponse.borrowed.rs
ListConfigResourcesResponse.owned.rs
ListGroupsRequest.borrowed.rs
ListGroupsRequest.owned.rs
ListGroupsResponse.borrowed.rs
ListGroupsResponse.owned.rs
ListOffsetsRequest.borrowed.rs
ListOffsetsRequest.owned.rs
ListOffsetsResponse.borrowed.rs
ListOffsetsResponse.owned.rs
ListPartitionReassignmentsRequest.borrowed.rs
ListPartitionReassignmentsRequest.owned.rs
ListPartitionReassignmentsResponse.borrowed.rs
ListPartitionReassignmentsResponse.owned.rs
ListTransactionsRequest.borrowed.rs
ListTransactionsRequest.owned.rs
ListTransactionsResponse.borrowed.rs
ListTransactionsResponse.owned.rs
MetadataRequest.borrowed.rs
MetadataRequest.owned.rs
MetadataResponse.borrowed.rs
MetadataResponse.owned.rs
NoOpRecord.borrowed.rs
NoOpRecord.owned.rs
OffsetCommitKey.borrowed.rs
OffsetCommitKey.owned.rs
OffsetCommitRequest.borrowed.rs
OffsetCommitRequest.owned.rs
OffsetCommitResponse.borrowed.rs
OffsetCommitResponse.owned.rs
OffsetCommitValue.borrowed.rs
OffsetCommitValue.owned.rs
OffsetDeleteRequest.borrowed.rs
OffsetDeleteRequest.owned.rs
OffsetDeleteResponse.borrowed.rs
OffsetDeleteResponse.owned.rs
OffsetFetchRequest.borrowed.rs
OffsetFetchRequest.owned.rs
OffsetFetchResponse.borrowed.rs
OffsetFetchResponse.owned.rs
OffsetForLeaderEpochRequest.borrowed.rs
OffsetForLeaderEpochRequest.owned.rs
OffsetForLeaderEpochResponse.borrowed.rs
OffsetForLeaderEpochResponse.owned.rs
PartitionChangeRecord.borrowed.rs
PartitionChangeRecord.owned.rs
PartitionRecord.borrowed.rs
PartitionRecord.owned.rs
ProduceRequest.borrowed.rs
ProduceRequest.owned.rs
ProduceResponse.borrowed.rs
ProduceResponse.owned.rs
ProducerIdsRecord.borrowed.rs
ProducerIdsRecord.owned.rs
PushTelemetryRequest.borrowed.rs
PushTelemetryRequest.owned.rs
PushTelemetryResponse.borrowed.rs
PushTelemetryResponse.owned.rs
ReadShareGroupStateRequest.borrowed.rs
ReadShareGroupStateRequest.owned.rs
ReadShareGroupStateResponse.borrowed.rs
ReadShareGroupStateResponse.owned.rs
ReadShareGroupStateSummaryRequest.borrowed.rs
ReadShareGroupStateSummaryRequest.owned.rs
ReadShareGroupStateSummaryResponse.borrowed.rs
ReadShareGroupStateSummaryResponse.owned.rs
RegisterBrokerRecord.borrowed.rs
RegisterBrokerRecord.owned.rs
RegisterControllerRecord.borrowed.rs
RegisterControllerRecord.owned.rs
RemoteLogSegmentMetadataRecord.borrowed.rs
RemoteLogSegmentMetadataRecord.owned.rs
RemoteLogSegmentMetadataSnapshotRecord.borrowed.rs
RemoteLogSegmentMetadataSnapshotRecord.owned.rs
RemoteLogSegmentMetadataUpdateRecord.borrowed.rs
RemoteLogSegmentMetadataUpdateRecord.owned.rs
RemotePartitionDeleteMetadataRecord.borrowed.rs
RemotePartitionDeleteMetadataRecord.owned.rs
RemoveAccessControlEntryRecord.borrowed.rs
RemoveAccessControlEntryRecord.owned.rs
RemoveDelegationTokenRecord.borrowed.rs
RemoveDelegationTokenRecord.owned.rs
RemoveRaftVoterRequest.borrowed.rs
RemoveRaftVoterRequest.owned.rs
RemoveRaftVoterResponse.borrowed.rs
RemoveRaftVoterResponse.owned.rs
RemoveTopicRecord.borrowed.rs
RemoveTopicRecord.owned.rs
RemoveUserScramCredentialRecord.borrowed.rs
RemoveUserScramCredentialRecord.owned.rs
RenewDelegationTokenRequest.borrowed.rs
RenewDelegationTokenRequest.owned.rs
RenewDelegationTokenResponse.borrowed.rs
RenewDelegationTokenResponse.owned.rs
RequestHeader.borrowed.rs
RequestHeader.owned.rs
ResponseHeader.borrowed.rs
ResponseHeader.owned.rs
SaslAuthenticateRequest.borrowed.rs
SaslAuthenticateRequest.owned.rs
SaslAuthenticateResponse.borrowed.rs
SaslAuthenticateResponse.owned.rs
SaslHandshakeRequest.borrowed.rs
SaslHandshakeRequest.owned.rs
SaslHandshakeResponse.borrowed.rs
SaslHandshakeResponse.owned.rs
ShareAcknowledgeRequest.borrowed.rs
ShareAcknowledgeRequest.owned.rs
ShareAcknowledgeResponse.borrowed.rs
ShareAcknowledgeResponse.owned.rs
ShareFetchRequest.borrowed.rs
ShareFetchRequest.owned.rs
ShareFetchResponse.borrowed.rs
ShareFetchResponse.owned.rs
ShareGroupDescribeRequest.borrowed.rs
ShareGroupDescribeRequest.owned.rs
ShareGroupDescribeResponse.borrowed.rs
ShareGroupDescribeResponse.owned.rs
ShareGroupHeartbeatRequest.borrowed.rs
ShareGroupHeartbeatRequest.owned.rs
ShareGroupHeartbeatResponse.borrowed.rs
ShareGroupHeartbeatResponse.owned.rs
SnapshotFooterRecord.borrowed.rs
SnapshotFooterRecord.owned.rs
SnapshotHeaderRecord.borrowed.rs
SnapshotHeaderRecord.owned.rs
StreamsGroupDescribeRequest.borrowed.rs
StreamsGroupDescribeRequest.owned.rs
StreamsGroupDescribeResponse.borrowed.rs
StreamsGroupDescribeResponse.owned.rs
StreamsGroupHeartbeatRequest.borrowed.rs
StreamsGroupHeartbeatRequest.owned.rs
StreamsGroupHeartbeatResponse.borrowed.rs
StreamsGroupHeartbeatResponse.owned.rs
StreamsGroupTopologyDescriptionUpdateRequest.borrowed.rs
StreamsGroupTopologyDescriptionUpdateRequest.owned.rs
StreamsGroupTopologyDescriptionUpdateResponse.borrowed.rs
StreamsGroupTopologyDescriptionUpdateResponse.owned.rs
SyncGroupRequest.borrowed.rs
SyncGroupRequest.owned.rs
SyncGroupResponse.borrowed.rs
SyncGroupResponse.owned.rs
TopicRecord.borrowed.rs
TopicRecord.owned.rs
TxnOffsetCommitRequest.borrowed.rs
TxnOffsetCommitRequest.owned.rs
TxnOffsetCommitResponse.borrowed.rs
TxnOffsetCommitResponse.owned.rs
UnregisterBrokerRecord.borrowed.rs
UnregisterBrokerRecord.owned.rs
UnregisterBrokerRequest.borrowed.rs
UnregisterBrokerRequest.owned.rs
UnregisterBrokerResponse.borrowed.rs
UnregisterBrokerResponse.owned.rs
UnregisterControllerRecord.borrowed.rs
UnregisterControllerRecord.owned.rs
UnregisterControllerRequest.borrowed.rs
UnregisterControllerRequest.owned.rs
UnregisterControllerResponse.borrowed.rs
UnregisterControllerResponse.owned.rs
UpdateFeaturesRequest.borrowed.rs
UpdateFeaturesRequest.owned.rs
UpdateFeaturesResponse.borrowed.rs
UpdateFeaturesResponse.owned.rs
UpdateRaftVoterRequest.borrowed.rs
UpdateRaftVoterRequest.owned.rs
UpdateRaftVoterResponse.borrowed.rs
UpdateRaftVoterResponse.owned.rs
UserScramCredentialRecord.borrowed.rs
UserScramCredentialRecord.owned.rs
VoteRequest.borrowed.rs
VoteRequest.owned.rs
VoteResponse.borrowed.rs
VoteResponse.owned.rs
VotersRecord.borrowed.rs
VotersRecord.owned.rs
WriteShareGroupStateRequest.borrowed.rs
WriteShareGroupStateRequest.owned.rs
WriteShareGroupStateResponse.borrowed.rs
WriteShareGroupStateResponse.owned.rs
WriteTxnMarkersRequest.borrowed.rs
WriteTxnMarkersRequest.owned.rs
WriteTxnMarkersResponse.borrowed.rs
WriteTxnMarkersResponse.owned.rs