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

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

第一种

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

第二种

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

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

kafka
发表于 2019-12-23
谢晓
添加评论

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

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

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

0 0 回复
你的答案

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

找不到想要的答案？提一个您自己的问题。