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