public class OffsetManager extends Object
Constructor and Description |
---|
OffsetManager() |
Modifier and Type | Method and Description |
---|---|
static Map<org.apache.kafka.common.TopicPartition,Long> |
getControlTopicOffset() |
static Map<org.apache.kafka.common.TopicPartition,Long> |
getEventsTopicOffset() |
static Properties |
load() |
static void |
saveControlTopic(Map<org.apache.kafka.common.TopicPartition,Long> newOffset) |
static void |
saveEventsTopic(Map<org.apache.kafka.common.TopicPartition,Long> newOffset) |
static void |
store(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetAndMetadataMap) |
public static void saveControlTopic(Map<org.apache.kafka.common.TopicPartition,Long> newOffset)
public static void saveEventsTopic(Map<org.apache.kafka.common.TopicPartition,Long> newOffset)
public static Map<org.apache.kafka.common.TopicPartition,Long> getControlTopicOffset()
public static Map<org.apache.kafka.common.TopicPartition,Long> getEventsTopicOffset()
public static Properties load()
public static void store(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetAndMetadataMap)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.