kafka原生api怎么动态创建消费线程

谢晓 发表于: 2019-12-23   最后更新时间: 2019-12-23 15:44:24   2,061 游览

第一种

@KafkaListener(topicPattern = "xxx-topic.*"),如果有新的topic创建是能拉取消息消费的。

第二种

consumer.subscribe(Pattern.compile("xxx-topic.*")),用这种如果新加topic是没有办法订阅动中途新建topic,只有重起服务才能消费

请问,用第二种原生api写消费者,怎么动态获取topic来创建消费线程

发表于 2019-12-23
添加评论

你用监听事件打印一下,看看是否能监听到中途创建的topic。

public void subscribe(Pattern pattern,
                      ConsumerRebalanceListener listener)
谢晓 -> 半兽人 4年前

你好,我试了下不可以监听中途创建的topic,如果已有topic是能正常消费的

你的答案

查看kafka相关的其他问题或提一个您自己的问题