I have downloaded confluent-5.1.2 in windows machine. Zookeeper is running successfully while running kafka server i am getting below exception. INFO Opening socket connection to server localhost/<unresolved>:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) WARN Session 0x0 for server localhost/<unresolved>:2181, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.nio.channels.UnresolvedAddressException at java.base/sun.nio.ch.Net.checkAddress(Net.java:149) ..
Category : apache-kafka
I’m writing a piece of code that needs to read hundreds of messages from Kafka each few milliseconds. I’m using C++ and librdkafka. When my program stops and then restarts it does not need to recover all lost messages since it was stopped, but instead it needs to always read from latest messages sent. As ..
I’m trying to set up 2 consumers with Rdkafka (C++) and try to have them be part of the same consumer group and consume from 2 different partitions of a topic. However I’m struggling to understand how this is achieved: from my understanding, using a consumer group means not having to directly choose which partition ..
I have problem starting producer in kafka on Microsoft Windows 10 Pro. Zookeper and kafka servers started ok. I also don’t have problem creating, listing and deleting topics. Here is error: WARN [Producer clientId=console-producer] Bootstrap broker localhost:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient) kafka version: 2.13-2.8.1 Source: Windows..
Am facing this issue while debugging code in VS code on windows OS. The code executes with no error but debugging isn’t happening. pkg-config –cflags — rdkafka pkg-config: exec: "pkg-config": executable file not found in %PATH% Source: Windows..
I have added certain aliases in .bashrc file, that point to the windows location of the start-server bat files of kafka and zookeeper. However when I run those in the gitbash its saying Command not found error Example if I have below alias in .bashrc file and I run the command zoo in gitbash it ..
Not able to start kafka server but my zookeeper is working fine C:kafka> .binwindowskafka-server-start.bat .configserver.properties The system cannot find the path specified. before this error i got wmic internal or external command then i put C:WindowsSystem32 in path variable of system variables after seeing in stackoverflow to sort out issue. version of kafka is 3.0.0 ..
I’m using the librdkafka c++ API and I would like to change the default behavior of the logger. In the c API there is this function rd_kafka_conf_set_log_cb() to set the log callback. It takes a function with the signature: void(*)(const rd_kafka_t *rk, int level, const char *fac, const char *buf) However I can’t figure out ..
I’ve been trying to run both zookeeper and kafka 2.13 on my local windows machine. I have modified the server properties to point to c:/kafka/kafka-logs and zookeeper data to point to c:/kafka/zookeeper-data. The zookeeper starts without any issues but when I attempt to start kafka with .binwindowskafka-server-start.bat .configserver.properties I get the below error saying AccessDeniedException. ..
I’ve downloaded latest version of Kafka from : https://www.apache.org/dyn/closer.cgi?path=/kafka/3.0.0/kafka_2.13-3.0.0.tgz and trying to make it start getting below error. I’ve change the path in the server.properties and zookeeper.properties. I was able to make zookeeper up, but Kafka creating lot of troubles. [2021-11-18 21:33:18,908] INFO Stat of the created znode at /brokers/ids/0 is: 42,42,1637251397733,1637251397733,1,0,0,72086256842768385,202,0,42 (kafka.zk.KafkaZkClient) [2021-11-18 21:33:18,913] ..
Web Development Company
Recent Comments