心中满是打伞的路人丶

0 声望

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

个人动态

半兽人 回复 心中满是打伞的路人丶 kafka消费者客户端(0.10.0.1API) 中 :
先提交offset,如果程序出错,打日志告警,人工介入(运行了几年不需要人工介入)。 注意关闭程序的时候优雅停机,防止offset提交了,消息还没来得及处理。
11天前
心中满是打伞的路人丶 kafka消费者客户端(0.10.0.1API) 发表评论:
如果我用一个线程来拉取消息,然后用一个线程池去处理拉下来的消息,如何管理offset的提交?
13天前
心中满是打伞的路人丶 kafka消费者客户端(0.10.0.1API) 发表评论:
是不是只有使用指定消费分区的方式(assign),才能够指定消费者的位置(seek)
21天前
半兽人 回复 心中满是打伞的路人丶 kafka中文教程 中 :
https://www.orchome.com/454 可以获取消费者组group1的详情,看看lag
22天前
关注了用户 半兽人 · 1月前

(゚∀゚ )
暂时没有任何数据