这家伙太懒,什么都没留下
先提交offset,如果程序出错,打日志告警,人工介入(运行了几年不需要人工介入)。注意关闭程序的时候优雅停机,防止offset提交了,消息还没来得及处理。
如果我用一个线程来拉取消息,然后用一个线程池去处理拉下来的消息,如何管理offset的提交?
是的
是不是只有使用指定消费分区的方式(assign),才能够指定消费者的位置(seek)
https://www.orchome.com/454可以获取消费者组group1的详情,看看lag