public class KafkaOffsetProvider extends Object
Constructor and Description |
---|
KafkaOffsetProvider() |
Modifier and Type | Method and Description |
---|---|
void |
closeConnection() |
kafka.javaapi.consumer.SimpleConsumer |
getConsumer() |
kafka.javaapi.consumer.SimpleConsumer |
getConsumer(String host,
int port) |
Map<String,Map<Integer,KafkaOffset>> |
getConsumerOffsetMap() |
long |
getLastOffset(kafka.javaapi.consumer.SimpleConsumer consumer,
String topic,
int partition,
long whichTime) |
void |
start() |
void |
stop() |
public kafka.javaapi.consumer.SimpleConsumer getConsumer()
public kafka.javaapi.consumer.SimpleConsumer getConsumer(String host, int port)
public Map<String,Map<Integer,KafkaOffset>> getConsumerOffsetMap()
public long getLastOffset(kafka.javaapi.consumer.SimpleConsumer consumer, String topic, int partition, long whichTime)
public void closeConnection() throws InterruptedException
InterruptedException
public void start()
public void stop() throws InterruptedException
InterruptedException
Copyright © 2018. All rights reserved.