search

childe / healer

golang lib for kafka
22 stars 18 forks source link

GroupConsumer hang under a certain condition #9

Closed childe closed 5 years ago

childe commented 5 years ago

bug in commit 00d8c0abb42dba2a9bbc992191978c92bc08d608

some simple consumers hang when group consumer want to stop it's all simple consumers and then restart them. simple consumer consume goroutine block in waiting innerMessamge channel, because the goroutine which send message to innerMessamge has returned.

reproduce

  1. goroutine break here https://github.com/childe/healer/blob/master/simple_consumer.go#L416
  2. stop = true
  3. goroutine return here https://github.com/childe/healer/blob/master/simple_consumer.go#L359
  4. block here https://github.com/childe/healer/blob/master/simple_consumer.go#L381