Thank you Dana. On Wed, May 4, 2016 at 4:25 PM, Dana Powers <dana.pow...@gmail.com> wrote:
> 0.8 clients manage groups by connecting directly to zookeeper and > implementing shared group management code. There are no broker APIs used. > > 0.9 clients manage groups using new kafka broker APIs. These clients no > longer connect directly to zookeeper. JoinGroupRequest is an 0.9 api. > > For an 0.8ish reimplementation, you might take a look at pykafka. There is > also the old Kafka Java code. I'm not aware of great docs, though. FWIW, > there are not many unofficial clients that have implemented group > management for 0.8 (unless they are just wrapping the official library > running on the jvm). > > -Dana > On May 4, 2016 02:52, "Zaiming Shi" <zmst...@gmail.com> wrote: > > Hi there! > > I'm investigating what it means to implement consumer group protocol for > 0.8. > However all the documents I can find on line is for 0.9 > e.g. > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+0.9+Consumer+Rewrite+Design > > Also, in kafka code base, JOIN_GROUP_REQUEST_V0 schema in 0.8 is different > from 0.9. > Why is the protocol upgraded without bumping the JoinGroupRequest API > version number? > > Anyone have some tips on where to start? > > Regards > -Zaiming >
