# Logstash Kafka Client Version 0.8 input and Elasticsearch-6.6 output **URL:** \ **Category:** Logstash\ **Created:** [February 27, 2019, 2:26am UTC](https://discuss.elastic.co/t/logstash-kafka-client-version-0-8-input-and-elasticsearch-6-6-output/170087 "2019-02-27T02:26:31Z")\ **Posts on this page:** 2\ **Page:** 1
**Author:** ![rpuserh](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/rpuserh/32/63367_2.png) [@rpuserh](https://discuss.elastic.co/u/rpuserh)\ **Post date:** [February 27, 2019, 2:26am UTC](https://discuss.elastic.co/t/logstash-kafka-client-version-0-8-input-and-elasticsearch-6-6-output/170087/1 "2019-02-27T02:26:32Z")
I need to find logstash which one will be compatible with Kafka Client Version 0.8 on input and Elasticsearch-6.6 on output I have kafka cluster and Kafka Client Version 0.8 compatible with it I'm running logstash-2.4 with logstash-input-kafka (2.0.9) and it successfully reads messages from kafka and writes them to ES Now I need to update ES cluster to 6.6 version and logstash-6.6.1 is unable to connect my kafka cluster I tried 5.x also didn't work, 2.4 cannot write to ES-6.6 I tried to upgrade logstash-output-elasticsearch plugin to version 9.3.2 on logstash-2.4 but it failed to write to ES-6.6.1 with error message ```auto Encountered a retryable error. Will Retry with exponential backoff {:code=>400, :url=>"http://172.17.0.2:9200/_template/logstash/_bulk", :level=>:error} Encountered a retryable error. Will Retry with exponential backoff {:code=>400, :url=>"http://172.17.0.2:9200/_template/logstash/_bulk/_bulk", :level=>:error} Encountered a retryable error. Will Retry with exponential backoff {:code=>400, :url=>"http://172.17.0.2:9200/_template/logstash/_bulk/_bulk/_bulk", :level=>:error} Encountered a retryable error. Will Retry with exponential backoff {:code=>400, :url=>"http://172.17.0.2:9200/_template/logstash/_bulk/_bulk/_bulk/_bulk", :level=>:error} Encountered a retryable error. Will Retry with exponential backoff {:code=>400, :url=>"http://172.17.0.2:9200/_template/logstash/_bulk/_bulk/_bulk/_bulk/_bulk", :level=>:error} ``` Then I tried to downgrade logstash-input-kafka plugin on logstash-6.6.1 to old version which worked on my old logstash (logstash-input-kafka (2.0.9)) And I get error during install See error below What else can i do in manner to achieve this problem? Thanks in advance. ```auto bash-4.2$ ./bin/logstash-plugin install --version 2.0.9 logstash-input-kafka Validating logstash-input-kafka-2.0.9 Installing logstash-input-kafka Plugin version conflict, aborting ERROR: Installation Aborted, message: Bundler could not find compatible versions for gem "logstash-core-plugin-api": In snapshot (Gemfile.lock): logstash-core-plugin-api (= 2.1.16) In Gemfile: logstash-devutils (= 1.3.5) java depends on logstash-core-plugin-api (<= 2.99, >= 2.0) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-azure_event_hubs (>= 0) java depends on logstash-core-plugin-api (~> 2.0) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-jdbc (>= 0) java depends on logstash-core-plugin-api (<= 2.99, >= 1.60) java logstash-input-kafka (= 2.0.9) java depends on logstash-core-plugin-api (~> 1.0) java logstash-core-plugin-api (>= 0) java Running `bundle update` will rebuild your snapshot from scratch, using only the gems in your Gemfile, which may resolve the conflict. ``` ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [March 27, 2019, 2:31am UTC](https://discuss.elastic.co/t/logstash-kafka-client-version-0-8-input-and-elasticsearch-6-6-output/170087/2 "2019-03-27T02:31:26Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.