Classes
CachedPartitionCountReader
CachedPublishers
Cached Publishers to reuse publisher of same settings in the same task.
CachedSubscriberClients
Singleton class that caches subscriber service clients to be re-used by the same task.
LimitingHeadOffsetReader
Rate limited HeadOffsetReader, utilizing a LoadingCache that refreshes all partitions head offsets for the topic at most once per minute.
MultiPartitionCommitterImpl
A MultiPartitionCommitter that lazily adjusts for partition changes when MultiPartitionCommitter#commit(PslSourceOffset) is called.