# Issue with kafka input plugin

**URL:** <https://discuss.elastic.co/t/issue-with-kafka-input-plugin/97451>\
**Category:** Logstash\
**Created:** [August 17, 2017, 3:40pm UTC](https://discuss.elastic.co/t/issue-with-kafka-input-plugin/97451 "2017-08-17T15:40:16Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![axelfelix](https://avatars.discourse-cdn.com/v4/letter/a/5fc32e/32.png) [@axelfelix](https://discuss.elastic.co/u/axelfelix)\
**Post date:** [August 17, 2017, 3:40pm UTC](https://discuss.elastic.co/t/issue-with-kafka-input-plugin/97451/1 "2017-08-17T15:40:16Z")

</div>

Hi all,

I am on my way to upgrade all my ELK cluster. The last point is the logtsash upgrade (before 2.3, future 5.5).  
Kafka version: 0.11.0.0

With logstash kafka input plugin version 2.0.6, I do not have any problem to get data from kafka and put it in elasticsearch.

But it doesn't work with logstash kafka input plugin version 5.1.8.

input plugin version 2.0.6 configuration:

> ```
> input{
> kafka{
> topic_id => "test"
> group_id => "mytest"
> type => "cisco-lan"
> zk_connect => "192.168.1.1:2181"
> codec => plain
> }
> }
> 
> ```

input plugin version 5.1.8 configuration:

> ```
> input{
> kafka{
> topics => ["test"]
> group_id => "mytest"
> type => "cisco-lan"
> bootstrap_servers => "192.168.1.1:2181"
> codec => plain
> }
> }
> 
> ```

I already try to change in server.properties configuration the line "advertised.host.name". No more success.

When I take a tcpdum I get Reset connection, I don't know why...

If you have any idea...

Thanks in advance,  
Alex

---

<div class="post-metadata">

**Author:** ![axelfelix](https://avatars.discourse-cdn.com/v4/letter/a/5fc32e/32.png) [@axelfelix](https://discuss.elastic.co/u/axelfelix)\
**Post date:** [August 17, 2017, 4:57pm UTC](https://discuss.elastic.co/t/issue-with-kafka-input-plugin/97451/2 "2017-08-17T16:57:48Z")

</div>

Solved using the port 9092 instead the port 2181.

Somebody knows why do I have to change the port between version 2.3 and 5.5 of Logstash ?

---

<div class="post-metadata">

**Author:** ![mwysokin](https://avatars.discourse-cdn.com/v4/letter/m/e9c0ed/32.png) [@mwysokin](https://discuss.elastic.co/u/mwysokin)\
**Post date:** [September 7, 2017, 10:12am UTC](https://discuss.elastic.co/t/issue-with-kafka-input-plugin/97451/3 "2017-09-07T10:12:47Z")

</div>

> [@axelfelix](#):
>
> Somebody

Yes, now you are connecting directly to kafka using so called "new consumer API". In the previous version you were actually connecting to ZooKeeper and not kafka. I assume you have them running on the same machine. That's why you didn't have to change the IP address.

---

<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:** [October 5, 2017, 10:13am UTC](https://discuss.elastic.co/t/issue-with-kafka-input-plugin/97451/4 "2017-10-05T10:13:09Z")

</div>

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