Hi All,
I am right now testing pushing logs in kafka und pulling them via logstash input kafka.
Versions:
kafka_2.11-2.0.0.tgz
logstash 6.4.0
I don't get any message via the logstash input, finding messages like this in the logs:
[INFO ] 2018-09-11 13:22:47.503 [Ruby-0-Thread-15: :1] AbstractCoordinator - [Consumer clientId=logstash-0, groupId=logstash] Discovered group coordinator ubuntu:9092 (id: 2147483647 rack: null)
[INFO ] 2018-09-11 13:22:47.510 [Ruby-0-Thread-15: :1] AbstractCoordinator - [Consumer clientId=logstash-0, groupId=logstash] Group coordinator ubuntu:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
After a little search I found:
So Kafka input is currently not working with latest Kafka Release? Which versions are working with logstash 6.4.0?