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..3d8bb0b8c0 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 @@ -30,6 +30,7 @@ * for record and batch listeners. * * @author Gary Russell + * @author JaeYeon Kim * @since 2.8 * */ @@ -46,7 +47,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; }