public class SinglePartitionWithoutOffsetsSystemAdmin extends java.lang.Object implements SystemAdmin
Constructor and Description |
---|
SinglePartitionWithoutOffsetsSystemAdmin() |
Modifier and Type | Method and Description |
---|---|
java.util.Map<SystemStreamPartition,java.lang.String> |
getOffsetsAfter(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
Fetches the offsets for the messages immediately after the supplied offsets
for a group of SystemStreamPartitions.
|
java.util.Map<java.lang.String,SystemStreamMetadata> |
getSystemStreamMetadata(java.util.Set<java.lang.String> streamNames)
Fetch metadata from a system for a set of streams.
|
java.lang.Integer |
offsetComparator(java.lang.String offset1,
java.lang.String offset2)
Compare the two offsets.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clearStream, createStream, deleteMessages, getSSPMetadata, start, stop, validateStream
public SinglePartitionWithoutOffsetsSystemAdmin()
public java.util.Map<java.lang.String,SystemStreamMetadata> getSystemStreamMetadata(java.util.Set<java.lang.String> streamNames)
SystemAdmin
getSystemStreamMetadata
in interface SystemAdmin
streamNames
- The streams to to fetch metadata for.public java.util.Map<SystemStreamPartition,java.lang.String> getOffsetsAfter(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
SystemAdmin
getOffsetsAfter
in interface SystemAdmin
offsets
- Map from SystemStreamPartition to current offsets.public java.lang.Integer offsetComparator(java.lang.String offset1, java.lang.String offset2)
SystemAdmin
offsetComparator
in interface SystemAdmin
offset1
- First offset for comparison.offset2
- Second offset for comparison.