Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix trailing whitespaces after previous merge

Browse Source
This commit is contained in:
Artem Bilan
2019-10-30 09:50:47 -04:00
parent adb2f9a231
commit f5bcaca16d
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -41,7 +41,7 @@ public class SeekToCurrentErrorHandler implements ContainerAwareErrorHandler {
@Override
public void handle(Exception thrownException, List<ConsumerRecord<?, ?>> records,
Consumer<?, ?> consumer, MessageListenerContainer container) {
if (thrownException instanceof SerializationException) {
throw new IllegalStateException("This error handler cannot process 'SerializationException's directly, "
+ "please consider configuring an 'ErrorHandlingDeserializer2' in the value and/or key "
@@ -50,7 +50,7 @@ public class SeekToCurrentErrorHandler implements ContainerAwareErrorHandler {
Map<TopicPartition, Long> offsets = new LinkedHashMap<>();
records.forEach(r ->
offsets.computeIfAbsent(new TopicPartition(r.topic(), r.partition()), k -> r.offset()));
offsets.computeIfAbsent(new TopicPartition(r.topic(), r.partition()), k -> r.offset()));
offsets.forEach(consumer::seek);
throw new KafkaException("Seek to current after exception", thrownException);
}