public interface ExtendedSystemAdmin extends SystemAdmin
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getNewestOffset(SystemStreamPartition ssp,
java.lang.Integer maxRetries) |
java.util.Map<java.lang.String,SystemStreamMetadata> |
getSystemStreamPartitionCounts(java.util.Set<java.lang.String> streamNames,
long cacheTTL) |
createChangelogStream, createCoordinatorStream, createStream, getOffsetsAfter, getSystemStreamMetadata, offsetComparator, validateChangelogStream, validateStream
java.util.Map<java.lang.String,SystemStreamMetadata> getSystemStreamPartitionCounts(java.util.Set<java.lang.String> streamNames, long cacheTTL)
java.lang.String getNewestOffset(SystemStreamPartition ssp, java.lang.Integer maxRetries)