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)