Interface | Description |
---|---|
CheckpointFile.EntryFormatter<T> |
This is used to convert the given entry of type
T into a string and vice versa. |
Class | Description |
---|---|
ApiMessageAndVersion |
An ApiMessage and an associated version.
|
CheckpointFile<T> |
This class represents a utility to capture a checkpoint in a file.
|
CheckpointFile.CheckpointReadBuffer<T> | |
CheckpointFile.CheckpointWriteBuffer<T> | |
Features | |
MetadataVersionValidator | |
OffsetAndEpoch | |
ProducerIdsBlock |
Holds a range of Producer IDs used for Transactional and EOS producers.
|
Enum | Description |
---|---|
MetadataVersion |
This class contains the different Kafka versions.
|
Exception | Description |
---|---|
AdminCommandFailedException | |
AdminOperationException |