public class ExternalOffsetStorage extends Object
| Constructor and Description |
|---|
ExternalOffsetStorage(ZookeeperConnection zookeeper) |
| Modifier and Type | Method and Description |
|---|---|
long |
getOffset(org.apache.kafka.common.TopicPartition partition)
Get the offset from Zookeeper for the given partition.
|
void |
saveOffset(org.apache.kafka.clients.consumer.Consumer consumer,
org.apache.kafka.common.TopicPartition partition)
Save the offset of the given partition in this consumer in zookeeper.
|
public ExternalOffsetStorage(ZookeeperConnection zookeeper)
public long getOffset(org.apache.kafka.common.TopicPartition partition)
partition - Partition to get the offset of.public void saveOffset(org.apache.kafka.clients.consumer.Consumer consumer,
org.apache.kafka.common.TopicPartition partition)
partition - Partition to save the offset of.Copyright © 2017 Grakn Labs Ltd. All rights reserved.