o
> > resolve the address that's killing it - my personal expectation would be
> > that even though zookeeper-2.zookeeper.etc may be down, its name should
> > still resolve.
> >
> > Regards,
> >
> > Liam Clarke
> >
> >
> >
> >
Hi,
I fail to start kafka broker when the corresponding zookeeper cluster is in
working but unhealthy state.
The zookeeper cluster is made of 3 nodes: zookeeper-0, zookeeper-1,
zookeeper-2.
I put all 3 zookeeper nodes into kafka's server.properties, specifically
for zookeeper.connect attribute a
Hi,
Does anyone publish or subscribe kafka topic in TestNG?
I try to publish and subscribe kafka topic in my TestNG test case, and I
always get the following exception:
2018-05-13 15:33:58.540 WARN
o.a.kafka.common.network.Selector.pollSelectionKeys[531] - [Producer
clientId=producer-1] Unexpect
Hi,
I can use "kafka-console-consumer.sh" to subscribe a topic on my kafka
broker, the consumer receives messages from kafka broker just fine.
However, when I try to subscribe the same topic in Java code with
spring-kafka, I get the UnsupportedVersionException error:
2018-04-19 06:42:30.124 ERROR
