public class TierTopicManagerCommitter
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Method and Description |
---|---|
void |
flush()
Flush TierPartition files to disk and then write consumer offsets to disk.
|
java.util.concurrent.ConcurrentHashMap<java.lang.Integer,java.lang.Long> |
positions() |
void |
run()
Main work loop.
|
void |
shutdown()
Initiate shutdown.
|
void |
updatePosition(java.lang.Integer partition,
java.lang.Long position)
Update position materialized by the TierTopicManager consumer.
|
public void shutdown()
public void updatePosition(java.lang.Integer partition, java.lang.Long position)
partition
- Tier Topic partitionIdposition
- Tier Topic Partition positionpublic java.util.concurrent.ConcurrentHashMap<java.lang.Integer,java.lang.Long> positions()
public void flush()
public void run()
run
in interface java.lang.Runnable