protocol library
Subpackage with implementation of Kafka protocol.
Users of this package are not supposed to import this library directly and use main 'kafka' package instead.
Classes
- Crc32
- CRC32 checksum calculator.
- FetchRequest
- Kafka FetchRequest.
- FetchResponse
- Kafka FetchResponse.
- FetchResult
- Data structure representing result of fetching messages for particular topic-partition.
- GroupCoordinatorRequest
- Kafka ConsumerMetadataRequest.
- GroupCoordinatorResponse
- Response for GroupCoordinatorRequest.
- KafkaBytesBuilder
- Bytes builder specific to Kafka protocol.
- KafkaBytesReader
- Provides convenience methods read Kafka specific data types from a stream of bytes.
- KafkaRequest
- Base interface for all Kafka API requests.
- MessageSet
- Kafka MessageSet type.
- MetadataRequest
- Kafka MetadataRequest.
- MetadataResponse
- Kafka MetadataResponse.
- OffsetCommitRequest
- Kafka OffsetCommitRequest.
- OffsetCommitResponse
- Kafka OffsetCommitResponse.
- OffsetCommitResult
- Data structure representing result of commiting of consumer offset.
- OffsetFetchRequest
- Kafka OffsetFetchRequest.
- OffsetFetchResponse
- Kafka OffsetFetchResponse.
- OffsetRequest
- Kafka OffsetRequest.
- OffsetResponse
- Kafka OffsetResponse.
- PartitionMetadata
- Data structure representing partition metadata returned in MetadataResponse.
- ProduceRequest
- Kafka ProduceRequest.
- ProduceResponse
- Kafka ProduceResponse.
- TopicMetadata
- Represents Kafka TopicMetadata data structure returned in MetadataResponse.
- TopicOffsets
- Data structure representing offsets of particular topic-partition returned by OffsetRequest.
- TopicProduceResult
- Data structure representing result of producing messages with ProduceRequest.