public class TierTopicReader extends Object
Constructor and Description |
---|
TierTopicReader(kafka.tier.backupObjectLifecycle.TierTopicReaderConfig config) |
Modifier and Type | Method and Description |
---|---|
long[] |
getConsumerPositions()
Returns the consumer positions.
|
List<ObjectStoreUtils.DeletionRecord> |
getDeletedSegments()
Consume the tier state topic and get information about segments that have been deleted by Kafka, since the last run
of this consumer.
|
boolean |
hasMoreRecordsToConsume()
Determines if the consumer has consumed till the end of all the subscribed partitions
|
void |
maybeCloseConsumer()
To be used by the caller to close the consumer
|
public TierTopicReader(kafka.tier.backupObjectLifecycle.TierTopicReaderConfig config)
public List<ObjectStoreUtils.DeletionRecord> getDeletedSegments() throws InterruptedException
InterruptedException
public long[] getConsumerPositions()
public boolean hasMoreRecordsToConsume()
public void maybeCloseConsumer()