From 3058e77d66c584ae984fc6401fde139df3e9689a Mon Sep 17 00:00:00 2001 From: Borahm Lee Date: Fri, 25 Oct 2024 14:36:49 +0900 Subject: [PATCH] Fix checkstyle violation --- .../support/converter/BatchMessagingMessageConverter.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/spring-kafka/src/main/java/org/springframework/kafka/support/converter/BatchMessagingMessageConverter.java b/spring-kafka/src/main/java/org/springframework/kafka/support/converter/BatchMessagingMessageConverter.java index 6c548ffa0d..09dd30cb4c 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/support/converter/BatchMessagingMessageConverter.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/support/converter/BatchMessagingMessageConverter.java @@ -176,7 +176,8 @@ public Message toMessage(List> records, @Nullable Acknow if (obj instanceof String) { listenerInfo = (String) obj; } - } else { + } + else { natives.add(record.headers()); } if (this.rawRecordHeader) { @@ -210,8 +211,8 @@ private void addToRawHeaders(Map rawHeaders, List record, Type type, List payloads, List keys, - List topics, List partitions, List offsets, List timestampTypes, - List timestamps, List conversionFailures) { + List topics, List partitions, List offsets, List timestampTypes, + List timestamps, List conversionFailures) { payloads.add(obtainPayload(type, record, conversionFailures)); keys.add(record.key()); topics.add(record.topic());