Support version 0 (zookeeper) and version 1 (kafka) protocol for commit offsets.

[nrandell]

Basic support working and unit tests running ok.

One unit test fails though - ProducerConsumerIntegrationTests - ConsumerShouldMoveToNextAvailableOffsetwhenQueryingForNextMessage is failing, but I don't think this is related.

[Jroland]

Nice Ill have a look

[Jroland]

@nrandell do you have a consumer written that is implementing the ConsumerCoordinator offset management APIs? Or was this patch just to get the offset commits working with 8.2?

[nrandell]

This was just to get the commits working.
On 2 Apr 2015 10:27 pm, "James Roland" [email protected] wrote:

@nrandell https://github.com/nrandell do you have a consumer written
that is implementing the ConsumerCoordinator offset management APIs? Or was
this patch just to get the offset commits working with 8.2?

—
Reply to this email directly or view it on GitHub
#48 (comment).

[Jroland]

@nrandell i have pulled this in to the integration branch. But I don't have a kafka 8.2 to test it against. I'll get it setup and tested on Tuesday. I think I need to start writing up some actual documentation for this now too. Specially with multiple versions coming out.