search

childe / healer

golang lib for kafka
22 stars 18 forks source link

极端情况可能导致新增加的 Partion 不消费 #11

Closed childe closed 4 years ago

childe commented 4 years ago

在 metadata 变化时, 触发 group consumer restart , 如果这个时候正好 heartbeat 也触发了 restart , 而且是先执行的, 可能会导致如下执行顺序:

  1. heart beat error , restart , lock , get metadata
  2. metadata change, restart , lock
  3. join , sync , consume (from step 1)

这样会导致 BUG