该
@KafkaListener有：
String id() default "";
属性，因此您可以
MessageListenerContainer通过提到的对其进行访问，您可以将其
KafkaListenerEndpointRegistry简单地
@Autowired引入基于Spring
Testing
framework的测试类中。然后，你才能真正
stop()和
start()那
MessageListenerContainer在您的测试方法。
也要注意如何
@KafkaListener也有一个
autoStartup()属性。
