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

How to correctly handle offsets?

2015-06-01 Thread luo.fucong
Hi all: I am using Kafka 0.8.2 and SimpleConsumer in maven: dependency groupIdorg.apache.kafka/groupId artifactIdkafka_2.11/artifactId version0.8.2.1/version /dependency I follow the SimpleConsumer example in the wiki, and there are some questions: 1. There seems lacking of how to