diff --git a/kamelets/kafka-not-secured-sink.kamelet.yaml b/kamelets/kafka-not-secured-sink.kamelet.yaml index 05a20deb9..04973aaa4 100644 --- a/kamelets/kafka-not-secured-sink.kamelet.yaml +++ b/kamelets/kafka-not-secured-sink.kamelet.yaml @@ -39,6 +39,8 @@ spec: - `partition-key` / `ce-partitionkey`: as message partition key Both the headers are optional. + + Three headers, if specified, will be deduplicated with different names, kafka.key will be duplicated into kafka.KEY, kafka.topic into kafka.TOPIC and kafka.override_topic into kafka.OVERRIDE_TOPIC required: - topic - bootstrapServers diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml index 05a20deb9..04973aaa4 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml @@ -39,6 +39,8 @@ spec: - `partition-key` / `ce-partitionkey`: as message partition key Both the headers are optional. + + Three headers, if specified, will be deduplicated with different names, kafka.key will be duplicated into kafka.KEY, kafka.topic into kafka.TOPIC and kafka.override_topic into kafka.OVERRIDE_TOPIC required: - topic - bootstrapServers