Remaining records not passed to RemainingRecordsErrorHandler

[abhinabasarkar]

As can be seen here -

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

Line 1231 in 7c512c9

if (this.errorHandler instanceof ContainerAwareErrorHandler) {

-that remaining records are passed only for ContainerAwareErrorHandler . RemainingRecordsErrorHandler implements ConsumerAwareErrorHandler and hence this.errorHandler.handle(e, record, this.consumer); is called which throws UnsupportedOperationException

[garyrussell]

Ref: https://gitter.im/spring-projects/spring-kafka?at=5c24f8e5db5b5c6883158523