这家伙太懒,什么都没留下
可以 客户端的producer console-producer都可以用 就客户端的consumer接收不到数据
文档:Kafka获取lag.note链接:https://note.youdao.com/noteshare?id=eb92186b5e03b5dcf605c92545fc5749
console-consumer能消费到消息吗
你使用的线程池是什么类型的?是不是线程池提交任务的时候阻塞了 把代码贴完整一点吧
订阅了 只是把部分代码截取出来