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);
-        }
+
     }
 }

Reply via email to