You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/07/16 05:22:49 UTC
[camel] 01/02: https://issues.apache.org/jira/browse/CAMEL-16807 :
Fixed a problem with KafkaConfiguration:copy()
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit b5a95f84a2c0d961bb1a79926f4db7fe939f0dc6
Author: Eric Wittmann <er...@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);