You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Anbumani Balusamy (JIRA)" <ji...@apache.org> on 2015/07/22 14:59:04 UTC
[jira] [Comment Edited] (CAMEL-8979) Camel Kafka component is using
Producer and KeyedMessage class
[ https://issues.apache.org/jira/browse/CAMEL-8979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14636585#comment-14636585 ]
Anbumani Balusamy edited comment on CAMEL-8979 at 7/22/15 12:58 PM:
--------------------------------------------------------------------
Hi Claus, I am working on this patch and we can this code only for new Project as we have lot of changes in new Producer config. For example in older version we have Producer config property name partitioner.class and we have variable name partitioner in KafkaConfiguration to hold the options value. But in new version the property name partitioner.class is completely removed and we need to remove it from KafkaConfiguration class too. If the existing application use this patch code (Simply upgrading the jar) then it might break the flow as they might be passing the options partitioner.class (ie..kafka:// ? partitioner.class) but no variable to hold this value in KafkaConfiguration class
was (Author: anbumani.balusamy):
Hi Claus, I am working on this patch and we can this code only for new Project as we have lot of changes in Producer config. For example in older version we have Producer config property name partitioner.class and we have variable name partitioner in KafkaConfiguration to hold the options value. But in new version the property name partitioner.class is completely removed and we need to remove it from KafkaConfiguration class too. If the existing application use this patch code (Simply upgrading the jar) then it might break the flow as they might be passing the options partitioner.class (ie..kafka:// ? partitioner.class) but no variable to hold this value in KafkaConfiguration class
> Camel Kafka component is using Producer and KeyedMessage class
> --------------------------------------------------------------
>
> Key: CAMEL-8979
> URL: https://issues.apache.org/jira/browse/CAMEL-8979
> Project: Camel
> Issue Type: Improvement
> Components: camel-kafka
> Reporter: Anbumani Balusamy
> Priority: Minor
>
> Hi, I looked into the camel-kafka component version 2.15.2 and it's using old Producer and KeyedMessage class for posting the message to kafka topic. From 0.8.2 version we have new KafkaProducer and ProduceRecord classes. Can we change the component to use the KafkaProducer and ProduceRecord classes?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)