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