[−][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 |