diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/CommonMixedErrorHandler.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/CommonMixedErrorHandler.java index a5b604c3b5..5a4ddd8340 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/CommonMixedErrorHandler.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/CommonMixedErrorHandler.java @@ -46,7 +46,7 @@ public class CommonMixedErrorHandler implements CommonErrorHandler { */ public CommonMixedErrorHandler(CommonErrorHandler recordErrorHandler, CommonErrorHandler batchErrorHandler) { Assert.notNull(recordErrorHandler, "'recordErrorHandler' cannot be null"); - Assert.notNull(recordErrorHandler, "'batchErrorHandler' cannot be null"); + Assert.notNull(batchErrorHandler, "'batchErrorHandler' cannot be null"); this.recordErrorHandler = recordErrorHandler; this.batchErrorHandler = batchErrorHandler; }