# Different Kafka versions for Input and Output

**URL:** <https://discuss.elastic.co/t/different-kafka-versions-for-input-and-output/131059>\
**Category:** Logstash\
**Created:** [May 8, 2018, 8:24pm UTC](https://discuss.elastic.co/t/different-kafka-versions-for-input-and-output/131059 "2018-05-08T20:24:18Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![gghdr](https://avatars.discourse-cdn.com/v4/letter/g/e19adc/32.png) [@gghdr](https://discuss.elastic.co/u/gghdr)\
**Post date:** [May 8, 2018, 8:24pm UTC](https://discuss.elastic.co/t/different-kafka-versions-for-input-and-output/131059/1 "2018-05-08T20:24:18Z")

</div>

Hi,

like the title, my use case is consuming from Kafka 0.10.2.1 and producing to Kafka 0.9.0.0

The plugin versions i'm using are 6.3.4 for Input and 4.2.0 for Output.

I'm able to consume but i'm having problems to produce; is this thing something that Logstash can do?

Thank you in advance for the support.

---

<div class="post-metadata">

**Author:** ![gghdr](https://avatars.discourse-cdn.com/v4/letter/g/e19adc/32.png) [@gghdr](https://discuss.elastic.co/u/gghdr)\
**Post date:** [May 9, 2018, 9:21am UTC](https://discuss.elastic.co/t/different-kafka-versions-for-input-and-output/131059/2 "2018-05-09T09:21:38Z")

</div>

An update.

My specific use case is connecting to IBM Message Hub Kafka 0.10.2.1; i followed this stack overflow thread ([https://stackoverflow.com/questions/46629331/unrecoverable-error-with-kafka-input-plugin-connecting-to-ibm-message-hub/46640611#46640611](https://stackoverflow.com/questions/46629331/unrecoverable-error-with-kafka-input-plugin-connecting-to-ibm-message-hub/46640611#46640611)) and i'm able to consume messages from the Brokers but i'm getting this errors when producing to my Kafka 0.9:

[DEBUG][org.apache.kafka.common.network.Selector] Connection with ..... disconnected  
java.io.EOFException: null  
at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) ~[kafka-clients-0.10.2.1.jar:?]

It seems that the Producer config gets the custom kafka-clients-0.10.2.1.jar that i added to the Consumer, but ONLY when both kafka input and kafka output are set inside the pipeline.

Any suggestion?

---

<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:** [June 6, 2018, 9:22am UTC](https://discuss.elastic.co/t/different-kafka-versions-for-input-and-output/131059/3 "2018-06-06T09:22:00Z")

</div>

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