Skip to content

Commit 5df2568

Browse files
garyrussellartembilan
authored andcommitted
Fix previous commit conflicts
1 parent 8cfd1d8 commit 5df2568

File tree

2 files changed

+1
-9
lines changed

2 files changed

+1
-9
lines changed

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

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -79,15 +79,6 @@ protected CommonErrorHandler getFallbackBatchHandler() {
7979
return this.fallbackBatchHandler;
8080
}
8181

82-
/**
83-
* Return the fallback batch error handler.
84-
* @return the handler.
85-
* @since 2.8.8
86-
*/
87-
protected CommonErrorHandler getFallbackBatchHandler() {
88-
return this.fallbackBatchHandler;
89-
}
90-
9182
protected void doHandle(Exception thrownException, ConsumerRecords<?, ?> data, Consumer<?, ?> consumer,
9283
MessageListenerContainer container, Runnable invokeListener) {
9384

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030
import org.springframework.core.log.LogAccessor;
3131
import org.springframework.kafka.support.TopicPartitionOffset;
3232
import org.springframework.lang.Nullable;
33+
import org.springframework.util.Assert;
3334
import org.springframework.util.backoff.BackOff;
3435

3536
/**

0 commit comments

Comments
 (0)