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