springboot手动启停kafka监听

在springboot项目中消费kafka消息使用@KafkaListener监听，参考代码如下：

@KafkaListener(id = "testListenerId" ,topics ={ "testTopicCode" }, groupId = "testGroupId")

本次主要是介绍怎么手动启停kafka监听：

1、首先是要为监听器设置ID，在@KafkaListener设置监听器的ID为：testListenerId

2、在类中注入Kafka的监听注册器

@Autowired
private KafkaListenerEndpointRegistry kafkaRegistry;

3、暂停监听

kafkaRegistry.getListenerContainer("testListenerId").pause();

4、恢复监听

kafkaRegistry.getListenerContainer("testListenerId").resume();