If you're attempting to run a heterogeneous consumer group (different clients joining same group) then you must take care that the group protocols have been implemented the same. kafka-python attempts to mirror the Java client exactly. I haven't looked at pykafka in a while, but it is possible that they ship a different implementation.
Happy to follow up on github/dpkp/kafka-python if you want to open a ticket there. -Dana On May 6, 2016 06:04, "Martin Gainty" <mgai...@hotmail.com> wrote: > > > > > To: users@kafka.apache.org > > From: michael.to...@headforwards.com > > Subject: Client Protocols > > Date: Fri, 6 May 2016 09:26:59 +0100 > > > > > > Hi, > > > > I'm doing some testing with two different kafka clients: pykafka and > > kafkapython > > > > When switching between client library, I get an error: > > InconsistentGroupProtocol > > > > I thought I was using latest protocol in both cases, but seems not. > > > > What different client protocols are there and is there a way I can check > > which is being used? > MG>I *thought* the protocol need to be listed in GroupProtocols array > during Join Group Request > > https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-TheProtocol > > > > > > Regards, > > > > Mike >
