This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 25e98faea7b18d5e0114b7686a3f7bd9d00fba79 Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Mon Jan 27 15:19:03 2025 +0100 CAMEL-21664: avoid unnecessary type cache miss --- .../camel/component/kafka/producer/support/ProducerUtil.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/ProducerUtil.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/ProducerUtil.java index 7563d08f2f4..d9e04a4e7ed 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/ProducerUtil.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/ProducerUtil.java @@ -75,9 +75,11 @@ public final class ProducerUtil { public static void setRecordMetadata(Object body, List<RecordMetadata> recordMetadataList) { if (body instanceof Exchange ex) { ex.getMessage().setHeader(KafkaConstants.KAFKA_RECORD_META, recordMetadataList); + } else { + if (body instanceof Message msg) { + msg.setHeader(KafkaConstants.KAFKA_RECORD_META, recordMetadataList); + } } - if (body instanceof Message msg) { - msg.setHeader(KafkaConstants.KAFKA_RECORD_META, recordMetadataList); - } + } }