[
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]/[~ancosen]/[~lb]
I took the latest code from Git and modified the Camel-Kafka component
to use the Java Implementation of Kakfa Producer/Consumer (Ver 0.9).
Please find the attachment Camel-Kafka component Project. Producer
logic is completed and consumer part is almost complete except the Junit
(KafkaConsumerBatchSizeTest & KafkaConsumerFullTest) as the new Consumer is
using the same thread of the Application making the call.
Kindly review the code (especially Consumer part) and let me know your
suggestions. FYI I have included 2 more classes (KafkaProducerTest &
KafkaConsumerTest) to test the Producer and consumer code and we can put these
classes logic in Documentation section as a sample implementation code.
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
>
>
> 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)
