Kafka input problem

Elastic Stack Logstash
1

I use kafka as input for my logstash
But it have a problem.

[2016-05-16 17:56:56,151] INFO Got user-level KeeperException when processing sessioni d:0x154b859cdaa0018 type:create cxid:0x15 zxid:0x24b txntype:-1 reqpath:n/a Error Path :/consumers/logstash/owners Error:KeeperErrorCode = NoNode for /consumers/logstash/own ers (org.apache.zookeeper.server.PrepRequestProcessor)

Thanks a lot for your support in advance.

2

It'd help if you could provide the config you have as well as what version you are on.

3

That looks like a Kafka version mismatch. I've seen that error when running 0.8.X brokers with 0.9 clients. They are not compatible. So what version is your Kafka broker and what version of Logstash are you running.