public class TierTopicReader extends Object
Constructor and Description |
---|
TierTopicReader(TierTopicReaderConfig config) |
Modifier and Type | Method and Description |
---|---|
long[] |
currentPositions()
Returns the consumer positions.
|
List<ObjectStoreUtils.DeletionRecord> |
deletedSegments()
Consume the tier state topic and get information about segments that have been deleted by Kafka, since the last run
of this consumer.
|
static Properties |
getProperties(TierTopicReaderConfig config) |
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(TierTopicReaderConfig config) throws InterruptedException
InterruptedException
public List<ObjectStoreUtils.DeletionRecord> deletedSegments() throws InterruptedException
InterruptedException
public long[] currentPositions()
public boolean hasMoreRecordsToConsume() throws InterruptedException
InterruptedException
public void maybeCloseConsumer()
public static Properties getProperties(TierTopicReaderConfig config)