Re: 0.8.x consumer group protocol

2016-05-05 Thread Zaiming Shi
Thank you Dana. On Wed, May 4, 2016 at 4:25 PM, Dana Powers 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

Re: 0.8.x consumer group protocol

2016-05-04 Thread Dana Powers
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 r

0.8.x consumer group protocol

2016-05-04 Thread Zaiming Shi
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