Questions tagged [apache-zookeeper]
Apache ZooKeeper is a distributed service that provides configuration information storage, naming, synchronization, coordination, and group services.
apache-zookeeper
1,546
questions with no upvoted or accepted answers
12
votes
7
answers
17k
views
Setting up a single Zookeeper instance and the binding fails
I am trying to set up a single zookeeper instance using the configuration below , however the start log indicates that the zookeeper is halting while trying to bind the port 2181.Can some one please ...
- 2,911
11
votes
0
answers
5k
views
How to resolve a zookeeper authentication failure when using Kafka with Kerberos
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....
- 1,632
11
votes
0
answers
2k
views
Read Data from HBase running on EMR Cluster with Spark installed on local machine
I have HBase running on EMR cluster and I'm trying to access the tables on it with Spark from local machine.
It seems that it connects to Zookeeper but can't find the table I'm looking for.
Here is my ...
- 111
10
votes
1
answer
4k
views
Kafka topic has partitions with leader=-1 (Kafka Leader Election), while node is up and running
I have a 3 member kafka-cluster setup, the __consumer_offsets topic has 50 partitions.
The following is the result of describe command on:
root@kafka-cluster-0:~# kafka-topics.sh --zookeeper ...
- 4,456
10
votes
0
answers
4k
views
Kafka No broker in ISR for partition
We have a Kafka cluster consists of 6 nodes. Five of the 6 nodes have zookeeper.
A spark streaming job is reading from a streaming server, do some processing, and send the result to Kafka.
From ...
- 2,768
9
votes
1
answer
18k
views
KAFKA: Connection to node failed authentication due to: Authentication failed due to invalid credentials with SASL mechanism SCRAM-SHA-256
I've been trying to add a SASL Authentication to my Kafka Brokers using SASL_PLAINTEXT SCRAM-SHA-256 for a while, but without any success. I keep getting the following error on Kafka's logfile.
...
- 99
8
votes
2
answers
3k
views
How do config tools like Consul "push" config updates to clients?
There is an emerging trend of ripping global state out of traditional "static" config management tools like Chef/Puppet/Ansible, and instead storing configurations in some centralized/distributed tool,...
- 29k
8
votes
0
answers
932
views
Curator - InterProcessMutex lock does not delete nodes
Does anybody know which of the Curator lock recipes creates ephemeral nodes ?
I tested InterProcessMutex lock but as far as I can see (with the zkClient) it does not delete the nodes after release or ...
- 81
8
votes
2
answers
1k
views
Is there a way to add watcher queue in zookeeper?
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) => {...
- 4,468
7
votes
0
answers
18k
views
Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
i configured 3 servers in zookeeper
this is zoo.cfg
tickTime=2000
initLimit=10
syncLimit=5
dataDir=/home/Alternant/zookeeper/zk1Data
clientPort=2181
server.1=localhost:2888:3888
server.2=localhost:...
- 91
7
votes
0
answers
1k
views
ZooKeeper session expired in tests
I'm using the EmbeddedKafka for testing my module with the following annotation confiugration:
@ExtendWith(SpringExtension.class)
@SpringBootTest
@TestPropertySource(locations = "classpath:test....
- 2,775
7
votes
0
answers
2k
views
Zookeeper in AWS ECS
I'm trying to launch a zookeeper cluster in AWS using Container Services. Using the base "zookeeper" docker image. There are two issues I'm currently having.
1) Zookeeper requires an "ZOO_MY_ID" ...
- 860
7
votes
1
answer
8k
views
Unable to start zookeeper (Last transaction was partial)
While I am trying to start zookeeper I am getting below error
[2017-05-24 11:52:31,633] ERROR Last transaction was partial. (org.apache.zookeeper.server.persistence.Util)
[2017-05-24 11:52:31,634] ...
- 301
7
votes
0
answers
3k
views
Cannot talk to ZooKeeper - Updates are disabled
We are facing one peculiar issue with Zoo Keeper wherein the ZK loses connectivity with solr cloud all of a sudden and starts throwing an Exception which says "Cannot talk to ZooKeeper - Updates are ...
- 71
7
votes
0
answers
2k
views
Connecting to Zookeeper via SSH port forwarding
I can connect locally to my Zookeeper instance:
[zookeeperServer]# zkCli.sh -server 127.0.0.1:2181
However if I try to do it via SSH forwarded port, it initially connects, but then immediately gets ...
- 1,693