diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java index 5d5c600f..378903be 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java @@ -198,8 +198,10 @@ public abstract class AbstractMessageListenerContainer synchronized (this.lifecycleMonitor) { if (!isRunning()) { Assert.isTrue( - this.containerProperties.getMessageListener() instanceof GenericMessageListener, - "A " + GenericMessageListener.class.getName() + " implementation must be provided"); + this.containerProperties.getMessageListener() instanceof MessageListener + || this.containerProperties.getMessageListener() instanceof AcknowledgingMessageListener, + "Either a " + MessageListener.class.getName() + " or a " + + AcknowledgingMessageListener.class.getName() + " must be provided"); doStart(); } }