camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anbumani Balusamy (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (CAMEL-9467) Camel-Kafka: Upgrade Producer/Consumer and their configuration properties
Date Fri, 04 Mar 2016 14:57:40 GMT

     [ 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.zip

Hi [~davsclaus],

	I have set the scope of the scala related jars to test in pom.xml and moved the kafka consumer
core logic to separate class which use Runnable. But after moving the code to the run() the
program stopped completely without consuming any message.I debug the code and after calling
the consumer.poll() inside run() only the program stopped.

	Kindly look into the code and let me know your suggestions/comments.

Thanks!
Anbu

> 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.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)

Mime
View raw message