# Logstash 6.0 or 5.5.0 and Kafka 0.10.0.1

**URL:** <https://discuss.elastic.co/t/logstash-6-0-or-5-5-0-and-kafka-0-10-0-1/112635>\
**Category:** Logstash\
**Created:** [December 20, 2017, 12:58pm UTC](https://discuss.elastic.co/t/logstash-6-0-or-5-5-0-and-kafka-0-10-0-1/112635 "2017-12-20T12:58:09Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![moriol](https://avatars.discourse-cdn.com/v4/letter/m/439d5e/32.png) [@moriol](https://discuss.elastic.co/u/moriol)\
**Post date:** [December 20, 2017, 12:58pm UTC](https://discuss.elastic.co/t/logstash-6-0-or-5-5-0-and-kafka-0-10-0-1/112635/1 "2017-12-20T12:58:09Z")

</div>

Hello,

I am trying to integrate Logstash with Kafka. Logstash works very well with Kafka as an output, but when configured as input, it doesnt work.  
In logs it seems that communication between Kafka and Logstash works well and that I am listening on Kafka topic, but nothing comes through.  
I can write to a topic, but cannot read from a topic with Logstash.  
My input is as follows:  
input {  
kafka {  
bootstrap\_servers =\> "10.20.30.40:9092"  
topics =\> "verified-topic"  
}  
}

Is there any reason this doesnt work? I tried Logstash version 6.0 and 5.5.0.

Kafka plugin version is:  
bin/logstash-plugin list --verbose logstash-input-kafka  
logstash-input-kafka (5.1.11)

In logs I see:  
[2017-12-20T13:32:07,525][INFO][org.apache.kafka.common.utils.AppInfoParser] Kafka version : 0.10.0.1  
[2017-12-20T13:32:07,525][INFO][org.apache.kafka.common.utils.AppInfoParser] Kafka commitId : a7a17cdec9eaa6c5  
[2017-12-20T13:32:07,659][INFO][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Discovered coordinator name-of-server:9092 (id: 2147483647 rack: null) for group logstash.  
[2017-12-20T13:32:07,661][INFO][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Revoking previously assigned partitions [] for group logstash  
[2017-12-20T13:32:07,661][INFO][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] (Re-)joining group logstash  
[2017-12-20T13:32:07,670][INFO][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Successfully joined group logstash with generation 15  
[2017-12-20T13:32:07,670][INFO][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Setting newly assigned partitions [verified-topic-0] for group logstash

---

<div class="post-metadata">

**Author:** ![moriol](https://avatars.discourse-cdn.com/v4/letter/m/439d5e/32.png) [@moriol](https://discuss.elastic.co/u/moriol)\
**Post date:** [December 21, 2017, 8:34am UTC](https://discuss.elastic.co/t/logstash-6-0-or-5-5-0-and-kafka-0-10-0-1/112635/2 "2017-12-21T08:34:37Z")

</div>

Any ideas?

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [January 18, 2018, 8:34am UTC](https://discuss.elastic.co/t/logstash-6-0-or-5-5-0-and-kafka-0-10-0-1/112635/3 "2018-01-18T08:34:44Z")

</div>

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