Class RmWatcher.LoadSnapshot
java.lang.Object
io.confluent.rm.api.RmWatcher.LoadSnapshot
- All Implemented Interfaces:
RmWatcher.InitializationStrategy
public static class RmWatcher.LoadSnapshot
extends Object
implements RmWatcher.InitializationStrategy
Start a watch stream with a full snapshot.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidaccept(BiConsumer<String, Boolean> tokenAndSnapshotConsumer) Apply the given consumer with the appropriate continueToken and includeSnapshot values.
-
Constructor Details
-
LoadSnapshot
public LoadSnapshot()
-
-
Method Details
-
accept
Description copied from interface:RmWatcher.InitializationStrategyApply the given consumer with the appropriate continueToken and includeSnapshot values.- Specified by:
acceptin interfaceRmWatcher.InitializationStrategy
-