风

0 声望

这家伙太懒，什么都没留下

个人动态
  • 随风而去 贬了 在 kafka中文教程 的评论!

    大神，我现在是上游生产100个topic，每个topic一个分区，现在用Java程序启动100个消费者，每个消费者对应1个topic，但是有时候poll 拉不到数据，while true一直空转，过10几秒就可以拉到数据，请问这个大概是什么原因？

    5年前
  • 风 回复 半兽人 在 kafka中文教程 中 ：

    大神的意思是第一次消费完就监控，没必要再去kafka再消费一次么？

    5年前
  • 半兽人 回复 风 在 kafka中文教程 中 ：

    你干嘛不用监控也重新消费一遍呢，不需要放到后面吧。

    5年前
  • 风 回复 半兽人 在 kafka中文教程 中 ：

    我把offset在map里面保存着。

    5年前
  • 半兽人 回复 风 在 kafka中文教程 中 ：

    你这个设计有问题呀，重置offset是慢的

    5年前
  • 风 回复 半兽人 在 kafka中文教程 中 ：

    对的。 kafkaConsumer.assign(Arrays.asList(topicp));
    kafkaConsumer.seek(topicp, startOffset);

    5年前
  • 关注了用户 半兽人 · 5年前