Environment : 6 server docker swarm cluster (2 master & 4 workers) Requirement : We need to setup a zookeeper cluster on existing docker swarm. Blocked on : To setup zookeeper in cluster, we ...

I have just started learning Kafka/Zookeper. Issue I am facing is, when I try to run the console consumer to verify the message for a topic, I get the below error- vagrant@debian-70rc1-x64-vbox421...

I have a Zookeeper path /xxx/yyy/zzz how can I copy/move it to another path without coding a script? Can I do that with some tool like zkCli.sh?

I recently scaled out a zookeeper cluster, and as part of the configuration change, we set leaderServes=no in order to increase throughput. This has worked out great, except for one problem: th...

I feel lost trying to figure out what my options are. Apache's programmers guide and administrators guide do not detail anything substantial. My O'Reilly Zookeeper book barely talks about security....

Is there any web-interface to check the data (or tree) present in the zookeeper? CLI is bit hard to get the complete picture of the tree and data.

I'm using confluent platform, the zookeeper is active with status lookup. but when I try to start kafka with confluent it shows zookeeper is down. $ sudo service zookeeper status Redirecting to /b...

As of now I am creating a topic one by one by using below command. sh ./bin/kafka-topics --create --zookeeper localhost:2181 --topic sdelivery --replication-factor 1 --partitions 1 Since I have ...

I am running a simple 3 node of kafka and 5 node of zookeeper to run the kafka, I would like to know which is the good way of backup my kafka, same for my zookeeper. For the moment I just export m...

From the ZooKeeper FAQ: Reliability: A single ZooKeeper server (standalone) is essentially a coordinator with no reliability (a single serving node failure brings down the ZK service). A 3 serve...

I have running an Apache Kafka cluster of five nodes, and I am using an Apache ZooKeeper cluster of three nodes. In zookeeper.properties file: server.1=zNode01:2888:3888 server.2=zNode02:2888:388...

I installed the stable version of kafka (0.8.1 with 2.9.2 Scala) as per their website and am running it with a 3 node zookeeper ensemble (3.4.6). I tried to create a test topic but keep seeing that...

As mentioned in the ZooKeeper Getting Started Guide , a minimum of three servers are required for a fault tolerant clustered setup, and it is strongly recommended that you have an odd number of ser...

There is a problem that bothers me. EndOfStreamExceptionalways happen in zookeeper after submitted topologies. Although it does not affect the normal operation of the cluster, I still hope to solve...

In Heron, I instantiated a SchedulerStateManagerAdaptor named adaptor using IStateManager and created a new Runtime config to saved this adaptor. Then, I created a ISchedulerClient object for invok...

One of the problems, I face with supervisord is that when I have a command which in turn spawns another process, supervisord is not able to kill it. For example I have a java process which when r...

I have the following structure: zookeeper: 3.4.12 kafka: kafka_2.11-1.1.0 server1: zookeeper + kafka server2: zookeeper + kafka server3: zookeeper + kafka Created topic with replication factor 3...

I'm trying to connect to single-node Kafka server through Docker but I am getting the following error: %3|1529395526.480|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bo...

bin/kafka-topics.sh --create --topic activityTopic --zookeeper localhost:2181/kafka --partitions 1 --replication-factor 1 The above command from kafka produces an error Error while executing top...

I am new to Mesos and just finished setting up mesos and along with zookeeper on my test server. Unfortunately I keep getting this error message on my mesos console indicating i am unable to conn...

Suppose we have several identical nodes which are the application servers of some n-tier service. And suppose we use Apache ZooKeeper to keep all the config's of our distributed application. Plus w...

System: EC2 Instance Type: m5.2xlarge OS: Ubuntu 14.04.5 LTS Kernel Version: 4.4.0-1022-aws vCPU: 8 Cores Memory: 32Gib Java Version: 1.8.0_171 We are running KAFKA in cluster mode with two ...

I am running 3 node zookeeper cluster to process storm and kafka.Zookeeper Data directory eats up all the space in my system.I am not sure how to clean it up.As, I don't want to delete the data ent...

We have an 8 node cluster using CDH3u2 configured using Cloudera Manager. We have a dedicated master node running our only instance of zookeeper. When I configure hive to run local hadoop, executed...

I was trying to use Zookeeper in our project. Could run the server..Even test it using zkcli.sh .. All good.. But couldn't find a good tutorial for me to connect to this server using Java ! All I n...