Fix checkstyle violation

spring-projects · Oct 25, 2024 · 3058e77 · 3058e77
1 parent 346b52b
commit 3058e77
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...main/java/org/springframework/kafka/support/converter/BatchMessagingMessageConverter.java b/...main/java/org/springframework/kafka/support/converter/BatchMessagingMessageConverter.java
@@ -176,7 +176,8 @@ public Message<?> toMessage(List<ConsumerRecord<?, ?>> 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<String, Object> rawHeaders, List<Map<String, Ob
 	}
 
 	private void addRecordInfo(ConsumerRecord<?, ?> record, Type type, List<Object> payloads, List<Object> keys,
-	    List<String> topics, List<Integer> partitions, List<Long> offsets, List<String> timestampTypes,
-		   List<Long> timestamps, List<ConversionException> conversionFailures) {
+		List<String> topics, List<Integer> partitions, List<Long> offsets, List<String> timestampTypes,
+		List<Long> timestamps, List<ConversionException> conversionFailures) {
 		payloads.add(obtainPayload(type, record, conversionFailures));
 		keys.add(record.key());
 		topics.add(record.topic());