有关kafka多线程启动多个Consumer报错的问题

■□ 微笑 ,只是对人~ 发表于: 2018-03-22   最后更新时间: 2018-03-22  
  •   0 订阅,221 游览

我使用多线程启动多个Conusmer这样的问题怎样解决啊 大神。
KafkaConsumer is not safe for multi-threaded access






征集:如果你也是一个热爱分享文章的人,愿意参与贡献文章来补充完善本网的内容,欢迎入群:14085484

发表于: 1月前   最后更新时间: 1月前   游览量:221
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • kafka获取消息的时候,是批量获取,例如一下获取2000-4000条,这个时候 你可以用多线去处理。而不是多线程去拉取数据。
    • 您好!我现在遇到的情况是在使用多线程处理拉取的消息后,相对而言拉取消息的耗时远超过处理时间,这种情况可以从哪些方面进行改进呢?
      • 评论…
        • in this conversation
          提问