[
https://issues.apache.org/jira/browse/CAMEL-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Akitoshi Yoshida resolved CAMEL-9511.
-------------------------------------
Resolution: Fixed
Fix Version/s: 2.17.0
2.16.3
> Setting Kafka's endpoint configuration by reference overrides everything
> instead of merging
> -------------------------------------------------------------------------------------------
>
> Key: CAMEL-9511
> URL: https://issues.apache.org/jira/browse/CAMEL-9511
> Project: Camel
> Issue Type: Improvement
> Components: camel-kafka
> Reporter: Serge Smertin
> Assignee: Akitoshi Yoshida
> Priority: Minor
> Fix For: 2.16.3, 2.17.0
>
>
> If we set configuration for Kafka endpoint as reference, the actual resulting
> configuration for endpoint is not merged and some query param-set properties
> are lost. It's easier to use shared configuration in cases us having global
> bean with zookeeper configuration and broker list.
> {code}
> @UriParam
> private KafkaConfiguration configuration = new KafkaConfiguration();
> ...
> @Override
> protected KafkaEndpoint createEndpoint(String uri,
> String remaining,
> Map<String, Object> params) throws
> Exception {
> KafkaEndpoint endpoint = new KafkaEndpoint(uri, this);
> String brokers = remaining.split("\\?")[0];
> if (brokers != null) {
> endpoint.getConfiguration().setBrokers(brokers);
> }
> setProperties(endpoint, params);
> return endpoint;
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
