Re: Getting first/last offset of a partition using KafkaConsumer

2016-04-18 Thread marko
Thanks, this seems to do the trick. Best regards, Marko www.kafkatool.com > Hi > > For the Kafka Consumer, there are seekToBeginning and seekToEnd method > that > point your the beginning and end of the partition. You can use one of the > methods to point the consumer to a certain position and u

Re: Getting first/last offset of a partition using KafkaConsumer

2016-04-17 Thread Liquan Pei
Hi For the Kafka Consumer, there are seekToBeginning and seekToEnd method that point your the beginning and end of the partition. You can use one of the methods to point the consumer to a certain position and use position(tp) method to get the corresponding position. There is also a seek(tp, offse

Getting first/last offset of a partition using KafkaConsumer

2016-04-17 Thread marko
How does one get the first/last offset for a given partition using the new KafkaConsumer/Producer? In the old SimpleConsumer you would just use the getOffsetsBefore() method. -- Best regards, Marko www.kafkatool.com