Skip to content

Commit 33e6848

Browse files
committed
Fix ListenerContainer to assert KafkaDataListener
https://build.spring.io/browse/SK-SK13X-32 **Cherry-pick to 1.2.x & 1.1.x** (cherry picked from commit 90cf576)
1 parent 161b367 commit 33e6848

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -198,7 +198,7 @@ public final void start() {
198198
synchronized (this.lifecycleMonitor) {
199199
if (!isRunning()) {
200200
Assert.isTrue(
201-
this.containerProperties.getMessageListener() instanceof GenericMessageListener,
201+
this.containerProperties.getMessageListener() instanceof KafkaDataListener,
202202
"A " + GenericMessageListener.class.getName() + " implementation must be provided");
203203
doStart();
204204
}

0 commit comments

Comments
 (0)