Crate kf_protocol_api

Macros

api_decode

Structs

Assignment

Batch

GroupAssignment

Metadata

ProtocolMetadata

Record

RecordHeader

RecordSet

ReplicaKey

RequestHeader

RequestMessage

Start of API request

ResponseMessage

Enums

AllKfApiKey

ErrorCode

kafka error https://kafka.apache.org/protocol#protocol_types

FlvErrorCode

Isolation

PartitionError

Constants

BATCH_HEADER_SIZE

BATCH_PREAMBLE_SIZE

size of the offset and length

MAX_BYTES

Traits

BatchRecords

KfApiKey

KfRequestMessage

PartitionOffset

Offset information about Partition

Request

Functions

create_partition_name

decompose_partition_name

Type Aliases

DefaultBatch

DefaultBatchRecords

DefaultRecord

Offset

Size