Logstash input plugin for kafka

i am having following error-

kafka client threw exception, restarting {:exception=>#<KafkaError: Got ZkException: Unable to

connect to zookeeper server within timeout: 6000>, :level

this is the my config file

kafka {
zk_connect => ",,"
topic_id => "UNIX"
group_id => "consumer-unix"
consumer_threads => 2

stdout {}

hosts => ""
index => "testunix_%{+YYYY.MM}"


Can you telnet to the ZK nodes from the LS host?

Yes I could telnet

Yes I could ..

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.