Hello,
I tried using the sources for unit tests, but have been unsuccessful in
getting it to work with the low level API (kafka version 0.8.2.2). Our
code is modelled on the Simple Consumer API code, and the error always
occurs in the findLeader code.
SEVERE: Error communicating with
Hi everyone,
Same errors can be seen when using embedded kafka and embedded zookeeper in
unit tests. They’re absolutely normal. As long as you see a successful
connection, it’s all good!
Kind regards,
Radek Gruchalski
ra...@gruchalski.com (mailto:ra...@gruchalski.com)
Hi Jeff,
I haven't tried this out, but I am planning to. Just a quick question : We
have TestHarness in Kafka that brings up Kafka and Zookeeper and also tears
them down. Have you tried using it?
Thanks,
Mayuresh
On Fri, Jul 10, 2015 at 10:09 AM, Jeff Gong j.gon...@gmail.com wrote:
To follow
To follow up and provide a little more context on my second bullet point,
when I run any command for the first time on command line that requires
connecting to this code instantiated ZK server I get the specific error:
bin/kafka-topics.sh --list --zookeeper localhost:2181
Hey Gwen,
Thanks for your response. The example was very helpful and exactly what I
was looking for! I went ahead and used that as an example and while most
things are working as I wanted, there are a few issues I'd like to follow
up on:
1. If I launch a Zookeeper/Kafka server from code instead
Hi all,
Is it possible to launch Kafka/Zookeeper servers via some part of the API?
I noticed in this:
http://stackoverflow.com/questions/16946778/how-can-we-create-a-topic-in-kafka-from-the-ide-using-api/
that it seems to be possible to create a ZK instance and add a topic to it,
but is this the
Is this for unit tests? Or do you need an embedded Kafka / ZK inside an app?
Or do you mean launching an external Kafka cluster, but without command line?
For unit tests / embedded, you can see this example:
https://gist.github.com/vmarcinko/e4e58910bcb77dac16e9
To start an actual Kafka server
