# Upgrade Logstash 5 -Kalfka plugin issue

**URL:** <https://discuss.elastic.co/t/upgrade-logstash-5-kalfka-plugin-issue/70225>\
**Category:** Logstash\
**Created:** [December 29, 2016, 4:43pm UTC](https://discuss.elastic.co/t/upgrade-logstash-5-kalfka-plugin-issue/70225 "2016-12-29T16:43:09Z")\
**Posts on this page:** 5\
**Page:** 1

<div class="post-metadata">

**Author:** ![sreejithps303](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/sreejithps303/32/23868_2.png) [@sreejithps303](https://discuss.elastic.co/u/sreejithps303)\
**Post date:** [December 29, 2016, 4:43pm UTC](https://discuss.elastic.co/t/upgrade-logstash-5-kalfka-plugin-issue/70225/1 "2016-12-29T16:43:09Z")

</div>

I am upgrading logstash from 2.3 to 5.1 . I am facing issue with kalfka input plugin. I have tried to remove the 5.1 plugin and install lower version but it is failing due to other dependencies.Also i have tried to change the input pattern to compatible to new plugin version. But looks like new plugin doesnt connect with zookeeper. can anyone suggest alternatives . please find my input pattern below.

input {  
kafka {  
zk\_connect =\> 'x:x:x:x:2181,x:x:x:x:2181,x:x:x:x:2181'  
white\_list =\> 'SubmitOrder,Conversion,Session,Navigation'  
consumer\_id =\> 'hostname'  
consumer\_threads =\> 4  
}  
}

---

<div class="post-metadata">

**Author:** ![sandeepkanabar](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/sandeepkanabar/32/79399_2.png) [@sandeepkanabar](https://discuss.elastic.co/u/sandeepkanabar)\
**Post date:** [January 6, 2017, 3:44pm UTC](https://discuss.elastic.co/t/upgrade-logstash-5-kalfka-plugin-issue/70225/2 "2017-01-06T15:44:00Z")

</div>

If you are using Logstash 5.x, then use the below:

```
input {
  kafka {
    bootstrap_servers => "xx.xx.xx.xx,yy.yy.yy.yy,zz.zz.zz.zz"
    topics => ["abc","def"]
    #decorate_events => true
  }
}
```

---

<div class="post-metadata">

**Author:** ![sreejithps303](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/sreejithps303/32/23868_2.png) [@sreejithps303](https://discuss.elastic.co/u/sreejithps303)\
**Post date:** [January 9, 2017, 4:39pm UTC](https://discuss.elastic.co/t/upgrade-logstash-5-kalfka-plugin-issue/70225/3 "2017-01-09T16:39:37Z")

</div>

Hi ,

thanks i have tried that too. looks like we cannot use zookeeper with logstash 5x and even we need to upgraede kafka to compatible with logstash 5x

---

<div class="post-metadata">

**Author:** ![sandeepkanabar](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/sandeepkanabar/32/79399_2.png) [@sandeepkanabar](https://discuss.elastic.co/u/sandeepkanabar)\
**Post date:** [January 9, 2017, 5:18pm UTC](https://discuss.elastic.co/t/upgrade-logstash-5-kalfka-plugin-issue/70225/4 "2017-01-09T17:18:33Z")

</div>

> [@sreejithps303](#):
>
> thanks i have tried that too

Didn't it work? Which version of Kafka are you using. I used `kafka_2.10-0.10.1.0`. So yes, you'd need to upgrade your kafka. The logstash input plugins doc should tell you which version would work with which.

---

<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:** [February 6, 2017, 5:18pm UTC](https://discuss.elastic.co/t/upgrade-logstash-5-kalfka-plugin-issue/70225/5 "2017-02-06T17:18:44Z")

</div>

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