[][src]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 Definitions

DefaultBatch
DefaultBatchRecords
DefaultRecord
Offset
Size