apache-zookeeper Questions
1
Solved
I have created a topic that has many partitions. Using the console producer I want to send messages to particular partitions and view the through the console consumer.
On the console producer I hav...
Procurance asked 14/5, 2018 at 6:31
1
Solved
I want to know if there is a way to walk the Zookeeper's (ZK) in memory database and find if any particular node exists. Something similar to find . -name file inside ZK
I am logged in to ZK using...
Tegument asked 2/5, 2018 at 1:15
2
I'm running Kafka (0.10.0.0) in a Docker on a Mac (w/docker-machine). I derived my Dockerfile from Spotify's, which means Kafka and Zookeeper run in the same image.
My instance starts cleanly and ...
Snip asked 5/6, 2016 at 21:7
1
Solved
I would like to deploy a Kafka cluster in two datacenters with the same number of nodes on each DC. The first DC is used in active mode while the second is in passive mode.
For example, let say th...
Stillness asked 28/2, 2018 at 10:50
4
Solved
One of the first things I think about when using a new service (such as a non-RDBMS data store or a message queue) is: "How should I structure my data?".
I've read and watched some introductory ma...
Daegal asked 20/6, 2013 at 4:55
5
Solved
I am trying to read messages on Kafka topic, but I am unable to read it. The process gets killed after sometime, without reading any messages.
Here is the rebalancing error which I get:
[2014-03-...
Claymore asked 21/3, 2014 at 15:50
7
Solved
Running zookeeper 3.3.3. I have a znode that I am just trying to list, via the CLI, as in:
ls /myznode/subznode
This crashes with an IOException in org.apache.ClientCnxn$SendThread.readLength at ...
Hobbema asked 20/4, 2012 at 16:1
1
Under these circumstances:
The client loses network connectivity to zk.
One minute passes.
The client regains network connectivity to zk.
I'm getting the following panic:
panic: close of close...
Hamblin asked 30/6, 2017 at 23:46
3
I am trying to run HBase on Ubuntu. I've installed it and can start it (it throws some warning because I'm using a 64-bit system but I'm told I can ignore these). However, when I try to start the s...
Blavatsky asked 3/12, 2015 at 12:41
2
Solved
I am going to implement the orchestration of a set of microservices in my application. Two widely using tools I found Apache Zookeeper and Netflix Eureka.
Can anyone please give a comparison based ...
Heyes asked 6/2, 2018 at 5:0
6
Solved
In my zookeeper/conf/log4j.properties file I set the zookeeper.log.dir to $HOME/zklogs
When I use zkServer.sh it does not use that directory. Instead it uses the ${ZOO_LOG_DIR} which when I echo i...
Momentous asked 28/10, 2014 at 15:58
3
Solved
How to recover from the following error that started happening after a server crash?
Zookeeper won’t start and the following message is showing repeatedly on the log.
2017-05-27 01:02:08,072 [my...
Franglais asked 27/5, 2017 at 13:51
2
I have a kafka cluster with 3 brokers. I have started facing issues lately with brokers going out of the cluster and producrs/consumers throwing leader not available errors.
On examining the logs ...
Charmion asked 9/10, 2017 at 10:55
1
Solved
I am using kafka as a message bus for Micro Service architecture, hence multiple services listen on a topic for a message. Therefore, the services are highly dependent on the topic to be live.
But...
Mitre asked 24/1, 2018 at 9:52
2
I am trying to have setup SASL authentication for my zookeeper for Kafka. I followed all the steps mentioned in below link
https://cwiki.apache.org/confluence/display/ZOOKEEPER/Client-Server+mutua...
Sakovich asked 1/8, 2017 at 15:5
3
Solved
I am trying to use JAVA API to connect to HBase.
My codes are shown below:
public class Test {
public static void main(String[] args) throws IOException{
TableName tableName = TableName.valueOf(...
Rumple asked 11/8, 2016 at 16:14
2
Solved
I have a Kafka cluster with 2 brokers, each on their own (AWS) server (I set up the cluster using the intstructions here). I am using SASL (but no encryption). On server 2, which runs broker 2, I c...
Aric asked 8/1, 2018 at 2:20
1
I am pretty new to Kubernetes and wanted to setup Kafka and zookeeper with it. I was able to setup Apache Kafka and Zookeeper in Kubernetes using StatefulSets. I followed this and this to build my ...
Checker asked 10/1, 2018 at 17:5
1
we have setup a Kafka/Zookeeper Cluster consisting of 3 Brokers. We have one producer, sending messages to one specific Kafka topic and a few consumer groups reading from said topic. Those consumer...
Tag asked 14/6, 2016 at 9:49
1
I know this has been asked before, so please forgive me for asking again, but none of the solutions pointed to by that thread worked for me.
I'm trying to setup Kafka 0.10.20 following the docs. W...
Mulder asked 22/4, 2017 at 12:40
2
I am using node-zookeeper-client for java script as a zookeeper client.
I have something like this:
const setWatch = (path, functionToExecuteOnTrigger) => {
client.getData(path, (event) =>...
Phox asked 21/12, 2017 at 11:51
1
Solved
How do I fix the problem that generates this error:
WARN [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:ZooKeeperServer@1040] - Client failed to SASL authenticate: javax.security.sasl.SaslException: G...
Atworth asked 22/12, 2017 at 0:43
0
I am trying to use SASL between my kafka broker and zookeeper. When I start the kafka server
KAFKA_OPTS="-Djava.security.auth.login.config=/home/kafka/kafka/config/kafka_server_jaas.conf -Djava.s...
Teleran asked 12/12, 2017 at 17:31
1
I'm using kafka-node to send messages between the services in my application. I'm using the wurstmeister/kafka and wurstmeister/zookeeper containers to run Kafka and Zookeeper (for simplicity's sak...
Garrygarson asked 1/9, 2015 at 11:14
2
when i starting kafka,zookeeper happens error.
INFO Got user-level KeeperException when processing sessionid:0x156028651c00001 type:delete cxid:0x1b zxid:0x59 txntype:-1 reqpath:n/a Error Path:/ad...
Durstin asked 19/7, 2016 at 9:52
© 2022 - 2024 — McMap. All rights reserved.