 | tangproxyV2EX 第 550695 号会员，加入于 2021-07-12 20:59:56 +08:00 |
tangproxy 最近回复了
215 天前 回复了 NoKey 创建的主题 Kafka 请问一下，多节点消费 kafka 如何做到串行消费 |
@vaynecv 赞同，后台服务多实例，初始化的时候通过分布式锁确定订阅 topic 的实例。然后，补充一点，防止这个订阅了 topic 的实例宕机，后台其他实例监听分布式锁过期的订阅，redission 那个，再进行重新抢锁，订阅 topic 。如果过期时间比较长（默认 10 分钟）无法接受的话，可以再加个补偿，举个例子，管理后台服务的程序（运管）可能最先知道后台实例挂了，通知其他实例这个情况。
Select Language