Re: How to correctly handle offsets?

2015-06-01 Thread svante karlsson
1) correlationId is just a number that you get back in your reply. you can safely set it to anything. If you have some kind of call identification is your system that you want to trace through logs - this is what you would use. 2) You can safely use any external offset management you like. just st

How to correctly handle offsets?

2015-06-01 Thread luo.fucong
Hi all: I am using Kafka 0.8.2 and SimpleConsumer in maven: org.apache.kafka kafka_2.11 0.8.2.1 I follow the SimpleConsumer example in the wiki, and there are some questions: 1. There seems lacking of how to commit the offset to Kafka. As far as I google it, it seems that I shoul