Logstash input plugin for kafka

Elastic Stack Logstash
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}"
}

}

2

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

3

Yes I could telnet

4

Yes I could ..

5

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