public interface TopicMetadataSnapshotCollector
Modifier and Type | Method and Description |
---|---|
default void |
deregisterSnapshotTask(kafka.utils.Scheduler scheduler) |
scala.Function0<scala.runtime.BoxedUnit> |
emitMetadataSnapshot()
Emit a topic metadata snapshot.
|
default kafka.utils.Scheduler |
registerSnapshotTask(int snapshotInitDelay,
int snapshotInterval) |
default kafka.utils.Scheduler registerSnapshotTask(int snapshotInitDelay, int snapshotInterval)
default void deregisterSnapshotTask(kafka.utils.Scheduler scheduler)
scala.Function0<scala.runtime.BoxedUnit> emitMetadataSnapshot()