All Apps and Add-ons
×

Are you a member of the Splunk Community?

Sign in or Register with your Splunk account to get your questions answered, access valuable resources and connect with experts!
cancel
Turn on suggestions
Auto-suggest helps you quickly narrow down your search results by suggesting possible matches as you type.
Showing results for 
Show  only  | Search instead for 
Did you mean: 
Ask a Question
Solved! Jump to solution

Splunk Add-on for Kafka: How to resolve multiple errors "No leader topic jsontest partition 0"?

sarnagar
Contributor
‎12-15-2016 04:36 AM

I can see soo many errors in splunkd.log. I am not understanding these. Could someone please guide?

12-15-2016 07:15:37.574 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:No leader for topic tesco-usage-demo partition 0
12-15-2016 07:15:37.576 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:No leader for topic jsontest partition 0
12-15-2016 07:15:37.576 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:No leader for topic tesco-usage-demo partition 0
12-15-2016 07:15:37.578 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:No leader for topic jsontest partition 0
12-15-2016 07:15:37.578 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:No leader for topic tesco-usage-demo partition 0
12-15-2016 07:15:37.580 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:No leader for topic jsontest partition 0
12-15-2016 07:15:37.580 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:No leader for topic tesco-usage-demo partition 0
12-15-2016 07:15:37.580 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:No leader for topic tesco-usage-demo partition 0
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.conn:Unable to connect to kafka broker at 10.109.136.210:9092
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" Traceback (most recent call last):
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"   File "/opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka/conn.py", line 220, in reinit
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"     self._sock = socket.create_connection((self.host, self.port), self.timeout)
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"   File "/opt/applocal/asts/vendor/splunk/forwarder/lib/python2.7/socket.py", line 571, in create_connection
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"     raise err
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" error: [Errno 111] Connection refused
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:Error sending request [1] to server 10.109.136.210:9092, trying next server
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" Traceback (most recent call last):
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"   File "/opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka/client.py", line 136, in _send_broker_unaware_request
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"     conn = self._get_conn(host, port)
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"   File "/opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka/client.py", line 59, in _get_conn
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"     timeout=self.timeout
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"   File "/opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka/conn.py", line 64, in __init__
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"     self.reinit()
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"   File "/opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka/conn.py", line 223, in reinit
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"     self._raise_connection_error()
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"   File "/opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka/conn.py", line 82, in _raise_connection_error
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py"     raise ConnectionError("Kafka @ {0}:{1} went away".format(self.host, self.port))
12-15-2016 07:15:39.573 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ConnectionError: Kafka @ xx.xxx.xxx.xxx:9092 went away
12-15-2016 07:15:39.575 -0500 ERROR ExecProcessor - message from "python /opt/applocal/asts/vendor/splunk/forwarder/etc/apps/Splunk_TA_kafka/bin/kafka_mod.py" ERROR:kafka.client:No leader for topic jsontest partition 0
@
0 Karma
Reply
1 Solution
Solved! Jump to solution
Solution

rdagan_splunk
Splunk Employee
Splunk Employee
‎12-21-2016 09:55 AM

It looks as if your main error is a connection to Kafka broker error:
ERROR:kafka.conn:Unable to connect to kafka broker at 10.109.136.210:9092

View solution in original post

Reply
Solved! Jump to solution
Solution

rdagan_splunk
Splunk Employee
Splunk Employee
‎12-21-2016 09:55 AM

It looks as if your main error is a connection to Kafka broker error:
ERROR:kafka.conn:Unable to connect to kafka broker at 10.109.136.210:9092

Reply
Solved! Jump to solution

sarnagar
Contributor
‎12-22-2016 02:14 AM

Ohhh...Let me try to resolve it first then..Thankyou for the info...

Also it would be great if you could help me on thsi issue as well 😞

https://answers.splunk.com/answers/482063/splunk-add-on-for-kafka-jmxlog-how-to-resolve-jmx.html

0 Karma
Reply
Career Survey
First 500 qualified respondents will receive a $20 gift card! Tell us about your professional Splunk journey.
Take the Survey
Get Updates on the Splunk Community!

Tech Talk Recap | Mastering Threat Hunting

Mastering Threat HuntingDive into the world of threat hunting, exploring the key differences between ...

Observability for AI Applications: Troubleshooting Latency

If you’re working with proprietary company data, you’re probably going to have a locally hosted LLM or many ...

Splunk AI Assistant for SPL vs. ChatGPT: Which One is Better?

In the age of AI, every tool promises to make our lives easier. From summarizing content to writing code, ...