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

谢晓 发表于: 2019-12-23   最后更新时间: 2019-12-23  

第一种

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

第二种

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

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



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: This message has failed its CRC checksum, exceeds the valid size, or is otherwise corrupt
下一条: kafka生产者依赖的kafka-client包,和消费者端依赖的kafka-client的版本不一致会有什么问题吗?

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

    public void subscribe(Pattern pattern,
                          ConsumerRebalanceListener listener)