Hi Robin, I believe seek() needs to be called after the consumer gets its partition assignments. Try calling poll() before you call seek(), then poll() again and process the records from the latter poll().
There may be a better way to do this -- let's see if anyone else has a suggestion. Alex On Wed, Feb 17, 2016 at 9:13 AM, Péricé Robin <perice.ro...@gmail.com> wrote: > Hi, > > I'm trying to use the new Consumer API with this example : > > https://github.com/apache/kafka/tree/trunk/examples/src/main/java/kafka/examples > > With a Producer I sent 1000 messages to my Kafka broker. I need to know if > it's possible, for example, to read message from offset 500 to 1000. > > What I did : > > > - consumer.seek(new TopicPartition("topic1", 0), 500); > > > - final ConsumerRecords<Integer, String> records = > consumer.poll(1000); > > > But this didn't nothing (when I don't use seek() method I consume all the > messages without any problems). > > Any help on this will be greatly appreciated ! > > Regards, > > Robin > -- *Alex Loddengaard | **Solutions Architect | Confluent* *Download Apache Kafka and Confluent Platform: www.confluent.io/download <http://www.confluent.io/download>*
