From 47ba3ba531d60ffdbd33fe14ed9be3b310f24233 Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Thu, 28 Sep 2017 13:27:51 -0400
Subject: [PATCH] Fix assertion in ListenerContainer.start()

https://build.spring.io/browse/SK-SK10X-39/
---
 .../kafka/listener/AbstractMessageListenerContainer.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

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<K, V>
 		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();
 			}
 		}