The MemberAssignment bytes returned in SyncResponse should be the bytes
that your leader sent in its SyncRequest. <<0, 0, 0, 0>> is simply an empty
Bytes array (32 bit length of 0). The broker does not alter those bytes as
far as I know, so despite the protocol doc describing what a
MemberAssignmen
I'm helping out on adding 0.9 stuff to the Elixir Kafka driver (
https://github.com/kafkaex/kafka_ex), and I'm getting an unexpected
response on an integration test that makes a simple SyncGroup call.
In Elixir terms, I'm getting <<0, 0, 0, 3, 0, 0, 0, 0, 0, 0>> back. My
interpretation:
32 bits c
Hi Muthu,
I checked in the ZK cli, I can see my created topic.Steps:-//enter the ZK shell
zookeeper-shell.sh crazybox:2181ls /brokers/topics[kafkatopic] -- this is the
topic that I created.
Thanks,Bhargo
On Saturday, March 26, 2016 9:46 PM, amar dev wrote:
Hi Muthu,
Thanks for replying.
Hi Muthu,
Thanks for replying.PFB my replies:-
Is your ZK running on the same system as one of broker instance ?
Yes, ZK, broker,console-producer, console-consumer are running on the same box
- Is broker able to connect to ZK properly ? May be this can be checked
via ZK CLI tools to check
Can you elaborate on this.
"Is broker able to connect to ZK properly ? May be this can be checked via
ZK CLI tools to check if the broker registrations happen properly as soon
as you start Kafka broker"
On Mar 26, 2016 8:18 AM, "Muthukumaran K"
wrote:
> Hi Bhargo,
>
> I ran into similar issues m
Hi Bhargo,
I ran into similar issues mainly due to firewall restrictions in my setup with
remote VM running broker and ZK. In my little experience, few things to check
concretely before running our own clients to see if the changes of
server.properties is properly done
-Is your ZK run
Hi Team!!
I am working on a POC for my project, where I want to replace RabbitMQ with
Kafka
I am using the 0.9.0.1 version of kafka on my Ubuntu 15.10 version.I have been
able to setup the basic setup, where from the console producer I can send
messages and from the console consumer, I can cons
Hello all,
I am trying to consume some topic using kafka-console-consumer.sh.
The problem is, I can consume nothing for a long time. there some infinite
print in the Client log like "SyncGroup for group example-group1 failed due to
UNKNOWN_MEMBER_ID, rejoining the group".
the print
Hi Jason
Thanks for looking into this.
Created this: https://issues.apache.org/jira/browse/KAFKA-3470
First time do it. Not sure if I have followed any necessary convention
there.
To your question:
No, this should not be a *significant* problem for any client as there
are workarounds (commit les
