High Level Consumer Example in 0.8.2

2015-03-12 Thread ankit tyagi
Hi All, we are upgrading our kafka client version from 0.8.0 to 0.8.2. Is there any document for High level kafka consumer withMultiple thread like https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example for this newer version.

Re: High Level Consumer Example in 0.8.2

2015-03-12 Thread Ewen Cheslack-Postava
You actually only need kafka_2.10-0.8.2.1 because it depends on kafka-clients-0.8.2.1 so the new producer code will get pulled in transitively. But there's nothing wrong with explicitly stating the dependency. However, I wouldn't mix versions (i.e. use kafka-clients-0.8.2.1 instead of

Re: High Level Consumer Example in 0.8.2

2015-03-11 Thread Ewen Cheslack-Postava
That example still works, the high level consumer interface hasn't changed. There is a new high level consumer on the way and an initial version has been checked into trunk, but it won't be ready to use until 0.9. On Wed, Mar 11, 2015 at 9:05 AM, ankit tyagi ankittyagi.mn...@gmail.com wrote:

Re: High Level Consumer Example in 0.8.2

2015-03-11 Thread ankit tyagi
Hi Ewen, I am using* kafka-clients-0.8.2.0.jar* client jar and i don't see above interface in that. which dependency do i need to include?? On Wed, Mar 11, 2015 at 10:17 PM, Ewen Cheslack-Postava e...@confluent.io wrote: That example still works, the high level consumer interface hasn't

Re: High Level Consumer Example in 0.8.2

2015-03-11 Thread Ewen Cheslack-Postava
Ah, I see the confusion now. The kafka-clients jar was introduced only recently and is meant to hold the new clients, which are pure Java implementations and cleanly isolated from the server code. The old clients (including what we call the old consumer since a new consumer is being developed, but

Re: High Level Consumer Example in 0.8.2

2015-03-11 Thread ankit tyagi
Hi Eden, Just One Question, if i want to have implementation for new producer then in that case i need to include below dependencies 1. *kafka-clients-0.8.2.0.jar (for new implementation of producer)* * 2. kafka_2.10-0.8.2.1 jar (for consumer )* As I see package of producer is different in