Questions tagged [apache-zookeeper]
Apache ZooKeeper is a distributed service that provides configuration information storage, naming, synchronization, coordination, and group services.
apache-zookeeper
3,714
questions
0
votes
0
answers
11
views
Unexpected Kafka request of type METADATA during SASL handshake while trying to connect with kafka server by a consumer
I'm trying to setup SASL plain authentication in kafka. But when I try to read a message or send a message, the Kafka Server logs the following error:
INFO [SocketServer listenerType=ZK_BROKER, nodeId=...
- 420k
32
votes
15
answers
86k
views
error while starting kafka broker
I was able to successfully set up zookeeper and one kafka broker yesterday. Everything worked as expected. I shut down kafka (ctrl + c) and then zookeeper.
Today I started zookeeper and when I ...
1
vote
3
answers
2k
views
Kafka broker message loss scenario on leadership change
I am trying to understand the following behavior of message loss in Kafka. Briefly, when a broker dies early on and subsequently after some message processing, all other brokers die. If the broker ...
- 11
-1
votes
0
answers
27
views
Kafka Streams with SASL Authenitattion
I am trying to secure my Kafka streams application (Java Springboot) with SASL_PLAINTEXT mechanism.
This is my docker-compose file
version: '3'
services:
zookeeper:
container_name: zookeeper
...
- 262
0
votes
0
answers
29
views
Custom Dockerfile and docker-compose.yml file for Kafka and Zookeeper containers doesn't produce and consume messages
I'm trying to create a custom Dockerfile and docker-compose.yml files for Kafka and Zookeeper services, in order to understand how to configure it, and how those services are communicated between each ...
0
votes
0
answers
21
views
zookeeper large memory size
I have a zk cluster set up , however, I ran into errors:
in zookeeper.properties, I have jute.maxbuffer=1073741824
But in zk logs during start up, I've got
2024-07-09 14:12:58,105 [myid:] - INFO [...
- 199
0
votes
1
answer
548
views
Kafka topic is not creating
I was installing kafka in Quickstart Cloudera VM using following link
but when i am running below command
kafka-topics --zookeeper quickstart.cloudera:2181 --create --topic test --partitions 1 --...
- 188k
1
vote
1
answer
44
views
error in linking zookeeper-client-c: unresolved symbols
so i have a simple module in C++ which uses some of the zookeeper-client-c API, particularly the functions:
zoo_exists, zoo_create, zoo_get_children, zoo_get, zookeeper_init, zookeeper_close
and ...
- 321
0
votes
1
answer
11k
views
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /lock/test3_node
I use Curator client to operate zookeeper server, but always failed if I start ten threads to operate zookeeper server concurrently.
It works fine if the threads number less than 6, while the ...
CommunityBot
- 1
0
votes
0
answers
19
views
Does zookeeper preserver order when moving sessions?
In the zookeeper book it says:
When a client creates a ZooKeeper handle using a specific language
binding, it establishes a session with the service. The client
initially connects to any server in ...
- 89
2
votes
2
answers
857
views
Zookeeper can't be started because of missing zookeeper-gc.log
I have a 3-node systemd kafka cluster. I had removed all log files in /opt/kafka/kafka/logs/ in 1 node, thought they were just storage-consuming logs. Now after restarting the zookeeper.service I get ...
- 25
2
votes
0
answers
734
views
zookeeper 3.6.2 c client compile failed
I downloaded the 3.6.2 source tarball (apache-zookeeper-3.6.2.tar.gz, sha512sum: ...
- 49
0
votes
0
answers
21
views
kafka broker restart failed without me knowing why
I'm facing an issue with my 3-node Kafka cluster, and perhaps you can help me troubleshoot.
Several times a day, I notice that my Kafka service restarts on my servers, and I'm struggling to understand ...
0
votes
0
answers
8
views
How to set a multiline value to a znode?
I have a znode as this:
[zk: localhost:2181(CONNECTED) 13] get /myapp/columns
column1 String
column2 Int64
I'd like to change column2 to String however I don't know how to have multiline.
[zk: ...
- 7,662
12
votes
2
answers
19k
views
Backup/restore kafka and zookeeper
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 my ...
- 208