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 613d12b1e37936a53b43d6a25a7334aa53102c2e Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Mon Jan 26 10:40:05 2026 +0000 (chores): modernize instanceof checks in camel-kafka --- .../org/apache/camel/component/kafka/KafkaHeaderDeserializer.java | 4 ++-- .../apache/camel/component/kafka/transform/TimestampRouter.java | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaHeaderDeserializer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaHeaderDeserializer.java index 645c1883b59f..bbe8eeb32623 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaHeaderDeserializer.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaHeaderDeserializer.java @@ -74,8 +74,8 @@ public class KafkaHeaderDeserializer implements Processor { return value; } - if (value instanceof byte[]) { - return new String((byte[]) value, StandardCharsets.UTF_8); + if (value instanceof byte[] byteArray) { + return new String(byteArray, StandardCharsets.UTF_8); } return value.toString(); diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/transform/TimestampRouter.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/transform/TimestampRouter.java index d0fac8221135..8987568a455d 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/transform/TimestampRouter.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/transform/TimestampRouter.java @@ -42,10 +42,10 @@ public class TimestampRouter { Long timestamp = null; String topicName = ex.getMessage().getHeader("kafka.TOPIC", String.class); Object rawTimestamp = ex.getMessage().getHeader(timestampHeaderName); - if (rawTimestamp instanceof Long) { - timestamp = (Long) rawTimestamp; - } else if (rawTimestamp instanceof Instant) { - timestamp = ((Instant) rawTimestamp).toEpochMilli(); + if (rawTimestamp instanceof Long longValue) { + timestamp = longValue; + } else if (rawTimestamp instanceof Instant instant) { + timestamp = instant.toEpochMilli(); } else if (ObjectHelper.isNotEmpty(rawTimestamp)) { timestamp = Long.parseLong(rawTimestamp.toString()); }
