Class KafkaOffsetProvider
- java.lang.Object
-
- org.opennms.core.ipc.sink.kafka.server.offset.KafkaOffsetProvider
-
public class KafkaOffsetProvider extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description KafkaOffsetProvider()
KafkaOffsetProvider(KafkaConfigProvider configProvider, com.codahale.metrics.MetricRegistry metricRegistry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
closeConnection()
org.apache.kafka.clients.consumer.KafkaConsumer
getConsumer()
org.apache.kafka.clients.consumer.KafkaConsumer
getConsumer(java.lang.String host, int port)
java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,KafkaOffset>>
getConsumerOffsetMap()
long
getLastOffset(org.apache.kafka.clients.consumer.KafkaConsumer consumer, java.lang.String topic, int partition, long whichTime)
com.codahale.metrics.MetricRegistry
getMetricRegistry()
void
setMetricRegistry(com.codahale.metrics.MetricRegistry metrics)
void
start()
void
stop()
-
-
-
Constructor Detail
-
KafkaOffsetProvider
public KafkaOffsetProvider()
-
KafkaOffsetProvider
public KafkaOffsetProvider(KafkaConfigProvider configProvider, com.codahale.metrics.MetricRegistry metricRegistry)
-
-
Method Detail
-
getMetricRegistry
public com.codahale.metrics.MetricRegistry getMetricRegistry()
-
setMetricRegistry
public void setMetricRegistry(com.codahale.metrics.MetricRegistry metrics)
-
getConsumer
public org.apache.kafka.clients.consumer.KafkaConsumer getConsumer()
-
getConsumer
public org.apache.kafka.clients.consumer.KafkaConsumer getConsumer(java.lang.String host, int port)
-
getConsumerOffsetMap
public java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,KafkaOffset>> getConsumerOffsetMap()
-
getLastOffset
public long getLastOffset(org.apache.kafka.clients.consumer.KafkaConsumer consumer, java.lang.String topic, int partition, long whichTime)
-
closeConnection
public void closeConnection() throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
start
public void start()
-
stop
public void stop() throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
-