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