I am building a kafka manager tool and I need to check which topic-partition is assigned to which consumer in a consumer group. Suppose there is consumer-Group group-A consuming topic topic-A with...

I have written a kafka consumer and producer that worked fine until today. This morning, when I started zookeeper and kafka, my consumer was not able to read messages, and I found this in the zooke...

I have read that copying the data directory will work. But, that is a combination of logs and snapshots. How do folks backup a zookeeper infrastructure ? Export ? Dump ? Custom script ? What are th...

I am trying to setup zookeeper on ec2 two instances. as given here and here. I am trying to run zookeeper which fails with an error: command: bin/zkCli.sh -server localhost:2181 > 2015-03-15 0...

Curator framework version - 4.3.0, Zookeeper version - 5.5.0 We have deployed apache atlas on Kubernetes and it uses Zookeeper to elect one out of two atlas pods as a leader. We are running three z...

I'm trying to start an hbase master from ambari. It can't start it because it can't connect to zookeper server. Ambari marks all the zookeper servers (3 nodes) as running. The application serve...

To install kafka , I downloaded the kafka tar folder. To start the server I tried this command : bin/zookeeper-server-start.sh config/zookeeper.properties The following error occured on enterin...

I'm trying to build ZooKeeper on a RedHat Linux box. (Exactly what ZooKeeper is is probably not important :-) When I follow the package instructions, I get: $ autoreconf -if aclocal:configure.ac...

i am new to the kafka world, i want to start zookeeper then when i type this bin/zookeeper-server-start.sh config/zookeeper.properties I got the following error ERROR Unexpected exception, exit...

I was trying to get the config for one of the kafka clusters we have. After doing a config change through puppet, I want to know if kafka has reloaded the config, or if we need to restart the servi...

I want to use both confluent/kafka and confluent/zookeeper and run them on a single Ubuntu server. I'm using the following configurations: docker run -e ZOOKEEPER_CLIENT_PORT=2181 --name zookeepe...

I am trying to install zookeeper and HBase in distributed mode but when I start my last node of zookeeper quorum I am getting excepton: 2013-09-05 12:02:09,230 - ERROR [main:QuorumPeer@171] - Sett...

For deleting a node in zookeeper from command line interface there is a delete command. When I run it, it says: Node not empty: /testNode I am using this guide.

I am new to Zookeeper and it has being a real issue to install it and run. I am not sure what is wrong in here but I will explain what I've being doing to make it more clear: 1.- I've followed the...

I want to delete a Kakfa consumer group so that when the application creates a consumer and subscribes to a topic it can start at the beginning of the topic data. This is with a single node develo...

I have been trying to deploy Kafka with schema registry locally using Kubernetes. However, the logs of the schema registry pod show this error message: ERROR Server died unexpectedly: (io.confluen...

I was trying to run Kafka on Windows machine and when I try to start the zookeeper I am facing this weird error: classpath is empty. please build the project first e.g. by running 'gradlew jaral...

I deployed a long running Storm topology. After several hours running, the whole topology went down. I checked worker logs, and found these logs . As it says, zookeeper client session timed out and...

I am trying to setup a Kafka cluster (the first node in the cluster actually). I have a single node zookeeper cluster setup. I am setting up kafka on a separate node. Both running CentOS 6.4, run...

Can anyone please help in enabling SASL authentication with wurstmeister/zookeeper and wurstmeister/kafka in docker compose? I run these without authentication and everything works fine, but I am n...

After around 6 months of using zookeeper in develop phase, though it works fine but the size of its data directory grew up to 6 GIG! and it is still increasing. Some of the system specifications ar...

I'm using Kafka's high-level consumer. Because I'm using Kafka as a 'queue of transactions' for my application, I need to make absolutely sure I don't miss or re-read any messages. I have 2 questio...

(I'm running on CentOS 5.8). I've been following the direction for a Clustered (Multiserver) Zookeeper Set-up, but getting an error when I try to start up my server. When I run the command as descr...

Well..every service in the world can connect to my zookeeper expect kafka. Below is my connection string in server.properties file zk.connect=1.dzk.syd.druid.neo.com:2181, 2.dzk.syd.druid.neo.com:...

I have three servers in my quorum. They are running ZooKeeper 3.4.5. Two of them appear to be running fine based on the output from mntr. One of them was restarted a couple days ago due to a deploy...