草庐IT

KafkaRegistry

全部标签

springboot集成kafka消费手动启动停止

项目场景:在月结,或者某些时候,我们需要停掉kafka所有的消费端,让其暂时停止消费,而后等月结完成,再从新对消费监听恢复,进行消费,此动作不需要重启服务,最后源码下载解决分析KafkaListenerEndpointRegistry这是kafka与spring集成的监听注册bean,可以通过它获取监听容器对象,然后对监听容器对象实行启动,暂停,恢复等操作/***kafka服务操作类*@authorliangxi.zeng*/@Service@Slf4jpublicclassKafkaService{@AutowiredprivateKafkaListenerEndpointRegistryr