public class KafkaOffsetProvider extends Object
Constructor and Description |
---|
KafkaOffsetProvider() |
KafkaOffsetProvider(KafkaConfigProvider configProvider,
com.codahale.metrics.MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
closeConnection() |
org.apache.kafka.clients.consumer.KafkaConsumer |
getConsumer() |
org.apache.kafka.clients.consumer.KafkaConsumer |
getConsumer(String host,
int port) |
Map<String,Map<Integer,KafkaOffset>> |
getConsumerOffsetMap() |
long |
getLastOffset(org.apache.kafka.clients.consumer.KafkaConsumer consumer,
String topic,
int partition,
long whichTime) |
com.codahale.metrics.MetricRegistry |
getMetricRegistry() |
void |
setMetricRegistry(com.codahale.metrics.MetricRegistry metrics) |
void |
start() |
void |
stop() |
public KafkaOffsetProvider()
public KafkaOffsetProvider(KafkaConfigProvider configProvider, com.codahale.metrics.MetricRegistry metricRegistry)
public com.codahale.metrics.MetricRegistry getMetricRegistry()
public void setMetricRegistry(com.codahale.metrics.MetricRegistry metrics)
public org.apache.kafka.clients.consumer.KafkaConsumer getConsumer()
public org.apache.kafka.clients.consumer.KafkaConsumer getConsumer(String host, int port)
public Map<String,Map<Integer,KafkaOffset>> getConsumerOffsetMap()
public long getLastOffset(org.apache.kafka.clients.consumer.KafkaConsumer consumer, String topic, int partition, long whichTime)
public void closeConnection() throws InterruptedException
InterruptedException
public void start()
public void stop() throws InterruptedException
InterruptedException
Copyright © 2020. All rights reserved.