Method and Description |
---|
org.apache.samza.system.SystemAdmin.createChangelogStream(String, int)
since 0.12.1, use
SystemAdmin.createStream(StreamSpec) |
org.apache.samza.system.SystemAdmin.createCoordinatorStream(String)
since 0.12.1, use
SystemAdmin.createStream(StreamSpec) |
org.apache.samza.system.SystemAdmin.validateChangelogStream(String, int)
since 0.12.1, use
SystemAdmin.validateStream(StreamSpec) |