[ 
https://issues.apache.org/jira/browse/CAMEL-9467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Anbumani Balusamy updated CAMEL-9467:
-------------------------------------
    Attachment: camel-kafka-Anbu.zip

[~davsclaus],

I took the .zip and cleanup the configuration parameters in the 
KafkaConfiguration to use constant fields for the option keys and removed the 
cyclic barriers logic. Please find the attached updated code. I tested the code 
using KafkaConsumerTest class in my local and still we have the same issue in 
consumer logic (Runnable).

> Camel-Kafka: Upgrade Producer/Consumer and their configuration properties
> -------------------------------------------------------------------------
>
>                 Key: CAMEL-9467
>                 URL: https://issues.apache.org/jira/browse/CAMEL-9467
>             Project: Camel
>          Issue Type: Task
>          Components: camel-kafka
>            Reporter: Andrea Cosentino
>            Assignee: Andrea Cosentino
>             Fix For: 2.17.0
>
>         Attachments: camel-kafka-Anbu.zip, camel-kafka-claus.zip, 
> camel-kafka.zip, camel-kafka.zip
>
>
> From release 0.9.0.0 the Kafka Consumer/Producer configuration properties 
> seems to be changed a little.
> Also we have to use the new Java implementation of Kafka Producer/Consumer, 
> actually we are using the Scala version



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to