[CAMEL-16701] Topic is not set if a KafkaConfiguration is used

• Type: Bug
• Status: Resolved
• Priority: Trivial
• Resolution: Fixed
• Affects Version/s: 3.7.3, 3.10.0
• Fix Version/s: 3.11.0
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Florian Eckhard
• Created: 09/Jun/21 21:53
• Updated: 10/Jun/21 04:16
• Resolved: 10/Jun/21 04:16

Description

If a KafkaConfiguration is used (see code) and no topic is defined in the configuration, the parameter from the URI is not taken over, but a null value is set.
This leads to a consumer not having a valid topic name, but null being provided as a value.

It looks like setProperties(endpoint, parameters); overrites the topic.

KafkaConfiguration

@Bean
public KafkaConfiguration kafkaConfig() {
     KafkaConfiguration kafkaConfiguration = new KafkaConfiguration();
     kafkaConfiguration.setBrokers(..);
     kafkaConfiguration.setClientId(..);
     //kafkaConfiguration.setTopic(kafkaTopic);
return kafkaConfiguration ;

Route

from(kafka({{topic.name}}?configuration=#kafkaConfig"))

Issue Links

• links to: GitHub Pull Request #5643