• 小可
    2019-10-17
    👍🏻
    
     2
  • Geek_72a3d3
    2019-10-17
    咦,回来一看,还有更新~,那我就不客气再请教个问题啦😄,胡夕老师或者黄云老师解答都可以~:
    请问kafka中的事务和Rocket MQ中的事务根本区别是什么,能不能用简单的几句话总结

    作者回复: Rocket MQ的事务机制我不太了解,不敢妄言,哈哈~

    
     1
  • 时间是最真的答案
    2019-11-26
    请问同一个id的多条数据,发送到同一个主题的多个分区,怎么保证相同id的多条数据被同一个consumer消费?

    作者回复: 赋值消息的key为该id,这样能保证它们去到同一个分区。

     1
    
  • KK
    2019-11-10
    80/20原则,刻意练习。
    
    
  • Flee
    2019-11-08
    老师你好,我们项目线上的kafka碰到了一个很奇怪的问题,kafka集群已经正常运行了快两年了没有任何问题,就在前几天,我们的一直使用的消费者组突然就不消费数据了。换一个消费者组就能消费到数据,但是过12个小时左右这个新的消费者组又不能消费数据了。这几天下来已经有好几百万的数据积压了。目前还没有找到原因。。。

    作者回复: 有什么报错日志吗?

    
    
  • 大力水手
    2019-11-07
    15
    66,057,323
    66,001,015
    56,308
    胡老师请教个问题、分区15不被发现、总是有消费积压、而且是一直递增、好像这个分区没有被发现一样?

    作者回复: 可能的原因有:1. 这个分区上有无法处理的消息或corrupted消息使得consumer无法跳过,你可以单独创建一个standalone consumer,只消费这个分区看看是否真的存在这样的消息;2. 你做过增加分区的操作,consumer需要一段时间才能发现这个新分区

    最好还是查一下日志,看看日志中有没有什么发现

     1
    
我们在线,来聊聊吧