Skip to content

Commit f5bcaca

Browse files
committed
Fix trailing whitespaces after previous merge
1 parent adb2f9a commit f5bcaca

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/SeekToCurrentErrorHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ public class SeekToCurrentErrorHandler implements ContainerAwareErrorHandler {
4141
@Override
4242
public void handle(Exception thrownException, List<ConsumerRecord<?, ?>> records,
4343
Consumer<?, ?> consumer, MessageListenerContainer container) {
44-
44+
4545
if (thrownException instanceof SerializationException) {
4646
throw new IllegalStateException("This error handler cannot process 'SerializationException's directly, "
4747
+ "please consider configuring an 'ErrorHandlingDeserializer2' in the value and/or key "
@@ -50,7 +50,7 @@ public void handle(Exception thrownException, List<ConsumerRecord<?, ?>> records
5050

5151
Map<TopicPartition, Long> offsets = new LinkedHashMap<>();
5252
records.forEach(r ->
53-
offsets.computeIfAbsent(new TopicPartition(r.topic(), r.partition()), k -> r.offset()));
53+
offsets.computeIfAbsent(new TopicPartition(r.topic(), r.partition()), k -> r.offset()));
5454
offsets.forEach(consumer::seek);
5555
throw new KafkaException("Seek to current after exception", thrownException);
5656
}

0 commit comments

Comments
 (0)