Logstash input plugin for kafka


(Sha198989) #1

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

input{
kafka {
zk_connect => "10.0.2.3:2181,10.0.2.4:2181,10.0.2.5:2181"
topic_id => "UNIX"
group_id => "consumer-unix"
consumer_threads => 2

output{
stdout {}

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

}


(Mark Walkom) #2

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


(shashant) #3

Yes I could telnet


(Sha198989) #4

Yes I could ..


(system) #5

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