Strange behavior, i working on configuring Kafka broker on my home server PC and trying to connect from another computer over wifi. The firewall port is opened on 9092 using following command netsh advfirewall firewall add rule name="TCP Port 9092" dir=in action=allow protocol=TCP localport=9092 However when i try to use Test-NetConnection to test the port ..
Hi Folks I am trying to create a kafka topic using kafka-topic command line tool, but it is keep on showing "the syntax of the command is incorrect" I am using kafka version 2.5.0 (Commit:66563e712b0b9f84) below are the commands that I tried but each time I am getting same error. .kafka-topics.bat –bootstrap-server broker:9092 –topic topic1 ..
I am trying to start apache server on my windows machine. But while doing so i get this error kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING and the process stops. Note that i have zookeeper process started before running this and it started fine. console log for zookeeper below:- [2021-02-20 16:24:30,818] INFO ..
I’m trying to build a project that uses modern-cpp-kafka but get an undefined reference to rd_kafka_err2str. I used vcpkg to install librdkafka and have the directories included in my CMakeLists file. All other librdkafka references work, I’m only experiencing this issue with rd_kafka_err2str. Adding -lrdkafka to my CMAKE_CXX_FLAGS didn’t seem to help. Here is the ..
I’m new to Apache Kafka. I’m trying to run their DemoApp in StreamAPI section and I get the following error in cmd: The syntax of the command is incorrect. Here’re the variants I’ve used: Variant 1: binwindowskafka-console-consumer.bat –bootstrap-server localhost:9092 –topic streams-wordcount-output –from-beginning –formatter kafka.tools.DefaultMessageFormatter –property print.key=true –property print.value=true Variant 2: binwindowskafka-console-consumer.bat –bootstrap-server localhost:9092 –topic streams-wordcount-output ..
I know Java services love Linux/Unix hosts much more. However, there are indeed some scenarios where it’s not always feasible to let customer install a Linux cluster in their environment just to deploy Kafka, i.e. Windows 10 / Windows Server may be their only acceptable choice. To describle our application briefly: not a service running ..
I have a kafka broker installed on windows and it works fine, but I also need to run it with SSL. How can I use SSL for Kafka on Windows? PS: Found just how to do it for Kafka on Linux. Source: Windows..
We are running with Kafka 2.11-2.4.1 on Windows 2012 R2. We found that after 48hrs the Kafka Broker is getting down with below error message. We found that deleting all Kakfa logs and restarting the Kafka broker would solve this issue but any one suggest for permanent solution. [2020-12-23 13:44:47,360] INFO [Log partition=DEVELOPER2017.dbo.Logins_Groups-0, dir=C:kafka_2.11-2.4.0binwindowskafka_2.11-2.4.0kafka-logs18] Found ..
[enter image description here] when I put my file data into kafka, and now I want to use consumer to consumption those data in kafka, but I always go this error,The syntax of the command is incorrect. and i can start kafka ,and if I test the test topic, it can work, [enter image description ..
I am getting data in json format on a kafka topic. I am connecting to it via Pyspark and creating dataframe over it and doing required transformations and finally writing the dataframe in json string format in Kafka topic. But I am getting following error for that: Traceback (most recent call last): File "C:Python37-32librunpy.py", line ..