Adam Kunicki created KAFKA-3191:
-----------------------------------
Summary: Improve offset committing JavaDoc in KafkaConsumer
Key: KAFKA-3191
URL: https://issues.apache.org/jira/browse/KAFKA-3191
Project: Kafka
Issue Type: Improvement
Components: consumer
Affects Versions: 0.9.0.0
Reporter: Adam Kunicki
Assignee: Neha Narkhede
Priority: Minor
http://www.confluent.io/blog/tutorial-getting-started-with-the-new-apache-kafka-0.9-consumer-client
includes some great examples of how to manage offset commits in Kafka 0.9.
It is currently unclear from the JavaDoc that the following is expected:
{code}
consumer.commitSync(Collections.singletonMap(record.partition(), new
OffsetAndMetadata(record.offset() + 1)));
{code}
The committed offset should always be the offset of the next message that
your application will read.
This information should be incorporated into the existing JavaDoc to make it
clearer.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
