该@KafkaListener有：

/**
 * The unique identifier of the container managing for this endpoint.
 * <p>If none is specified an auto-generated one is provided.
 * @return the {@code id} for the container managing for this endpoint.
 * @see org.springframework.kafka.config.KafkaListenerEndpointRegistry#getListenerContainer(String)
 */
String id() default "";

属性，因此您可以MessageListenerContainer通过提到的对其进行访问，您可以将其KafkaListenerEndpointRegistry简单地@Autowired放入基于Spring
Testing
Framework的测试类中。然后，你才能真正stop()和start()那MessageListenerContainer在您的测试方法。

也要注意如何@KafkaListener也有一个autoStartup()属性。