This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-3.11.x in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.11.x by this push: new acc1e47 https://issues.apache.org/jira/browse/CAMEL-16807 : Fixed a problem with KafkaConfiguration:copy() acc1e47 is described below commit acc1e47a78ec6ab3fb1c604378f8b6013f7d3fb7 Author: Eric Wittmann <eric.wittm...@gmail.com> AuthorDate: Thu Jul 15 08:17:07 2021 -0400 https://issues.apache.org/jira/browse/CAMEL-16807 : Fixed a problem with KafkaConfiguration:copy() --- .../main/java/org/apache/camel/component/kafka/KafkaConfiguration.java | 1 + 1 file changed, 1 insertion(+) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java index ffdc9ce..febab8c 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java @@ -343,6 +343,7 @@ public class KafkaConfiguration implements Cloneable, HeaderFilterStrategyAware public KafkaConfiguration copy() { try { KafkaConfiguration copy = (KafkaConfiguration) clone(); + copy.additionalProperties = new HashMap<>(this.additionalProperties); return copy; } catch (CloneNotSupportedException e) { throw new RuntimeCamelException(e);