本文介绍: kafka中如何实现动态开启 暂停消费者
Kafka中如何动态开启、关闭消费者
使用背景:在开发业务中需要根据具体逻辑选择开启还是关闭消费者
实现逻辑:
1、创建consumer配置类,自定义工厂、自定义消费者配置(省略)
还需要注入consumerService bean(改类里主要是控制动态启停的具体实现方法)
2、接口实现
消费监听方法上,@KafkaListener(topicPattern=“${topicPattern}”,id=“XXX”,idIsGroup = false)即可监听开启消费的topic数据
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。