A little question£¬ when old message log is deleted£¬ the start point offset is changed. If a simple consumer seek a offset less than start point offset, what will happen? Read all message from start? 2013/4/2 Jason Rosenberg <[EMAIL PROTECTED]>
On Mon, Apr 1, 2013 at 8:44 PM, Yonghui Zhao <[EMAIL PROTECTED]> wrote: Standard Kafka Consumer code will raise an OffsetOutOfRange exception. How that is handled depends on the the type of Consumer you use -- Simple or High-Level. I believe the latter moves you to the next available offset.
If you use the high-level consumer, when the consumer gets an OffsetOutofRangeException, it will automatically reset to either the smallest or the largest available offset, depend on the config autooffset.reset.
On Mon, Apr 1, 2013 at 8:44 PM, Yonghui Zhao <[EMAIL PROTECTED]> wrote:
I've often wondered about what it would take to be able to overwrite a specific offset in a partition (it could be very useful for transaction rollbacks, message deletions, etc). Unfortunately, I don't think that feature currently exists.
On Mon, Apr 1, 2013 at 11:14 PM, Pankaj Misra <[EMAIL PROTECTED]>wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation projects and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext