Do I understand correctly that poll() will return a subset of the messages
in a topic each time it is called? So if I want to replay all messages, I
would seek to the beginning and call poll in a loop? Not easily knowing
when I was done, without a high watermark

https://issues.apache.org/jira/browse/KAFKA-2076

This is a pretty basic question, but I don't think it is explained in the
JavaDoc

http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html

Thanks

Reply via email to