第一种 @KafkaListener(topicPattern = "xxx-topic.*"),如果有新的topic创建是能拉取消息消费的。 第二种 consumer.subscribe(Pattern.compile("xxx-topic.*")),用这种如果新加topic是没有办法订阅动中途新建topic,只有重起服务才能消费 请问,用第二种原生api写消费者,怎么动态获取topic来创建消费线程
你用监听事件打印一下,看看是否能监听到中途创建的topic。
public void subscribe(Pattern pattern, ConsumerRebalanceListener listener)
你好,我试了下不可以监听中途创建的topic,如果已有topic是能正常消费的
你的答案