# Logstash kafka-input-plugin problem **URL:** \ **Category:** Logstash\ **Created:** [December 11, 2016, 9:30am UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-problem/68640 "2016-12-11T09:30:47Z")\ **Posts on this page:** 2\ **Page:** 1
**Author:** ![antimion](https://avatars.discourse-cdn.com/v4/letter/a/977dab/32.png) [@antimion](https://discuss.elastic.co/u/antimion)\ **Post date:** [December 11, 2016, 9:30am UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-problem/68640/1 "2016-12-11T09:30:47Z")
Hi all, i have a problem with kafka-input, my kafka version is 0.9.0.1 (cloudera distribution), and they need zk\_connect string to connect to the brokers, but in new version zk\_connect changed to bootstrap\_servers. and now when i try to start logstash it try to connect to kafka broker "[org.apache.kafka.common.utils.AppInfoParser] Kafka version : 0.10.0.1" > Exception in thread "Ruby-0-Thread-27: /opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-input-kafka-5.1.0/lib/logstash/inputs/kafka.rb:225" Exception in thread "Ruby-0-Thread-12: /opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-input-kafka-5.1.0/lib/logstash/inputs/kafka.rb:225" org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'brokers': Error reading field 'host': Error reading string of length 28281, only 1810 bytes available i try to install old versions of logstash-input-kafka, but it didn't help. can you please provide the solution of this situation, because i can't change kafka version. ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [January 8, 2017, 9:30am UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-problem/68640/2 "2017-01-08T09:30:56Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.