Class PartitionCountWatcherImpl.Factory (1.12.0)

public static class PartitionCountWatcherImpl.Factory implements PartitionCountWatcher.Factory

Inheritance

java.lang.Object > PartitionCountWatcherImpl.Factory

Constructors

Factory(TopicPath topicPath, AdminClient adminClient, AlarmFactory alarmFactory)

public Factory(TopicPath topicPath, AdminClient adminClient, AlarmFactory alarmFactory)
Parameters
NameDescription
topicPathTopicPath
adminClientAdminClient
alarmFactoryAlarmFactory

Methods

newWatcher(Consumer<Long> receiver)

public PartitionCountWatcher newWatcher(Consumer<Long> receiver)
Parameter
NameDescription
receiverConsumer<Long>
Returns
TypeDescription
PartitionCountWatcher