Interface | Description |
---|---|
PartitionFilter | |
Scheduler |
A scheduler for running jobs
This interface controls a job scheduler that allows scheduling either repeating background jobs
that execute periodically or delayed one-time actions that are scheduled in the future.
|
TopicPartitionFilter |
Class | Description |
---|---|
CommandDefaultOptions | |
CommandLineUtils |
Helper functions for dealing with command line utilities.
|
Deadline | |
FutureUtils | |
InterBrokerSendThread |
An inter-broker send thread that utilizes a non-blocking network client.
|
Json |
Provides methods for parsing JSON with Jackson and encoding to JSON with a simple and naive custom implementation.
|
KafkaScheduler |
A scheduler based on java.util.concurrent.ScheduledThreadPoolExecutor
It has a pool of kafka-scheduler- threads that do the actual work.
|
PartitionFilter.PartitionRangeFilter | |
PartitionFilter.PartitionsSetFilter | |
PartitionFilter.UniquePartitionFilter | |
RequestAndCompletionHandler | |
ShutdownableThread | |
ThroughputThrottler |
This class helps producers throttle throughput.
|
TopicFilter | |
TopicFilter.IncludeList | |
TopicPartitionFilter.CompositeTopicPartitionFilter | |
TopicPartitionFilter.TopicFilterAndPartitionFilter | |
TranslatedValueMapView<K,V,B> |
A map which presents a lightweight view of another "underlying" map.
|