У меня есть воркер, в котором используются 3 горутины с использованием consumer.ReadMessage(-1), и когда я вызываю consumer.Close(), некоторые из этих горутин (2) застревают на consumer.ReadMessage(-1).
Похоже, что до Close некоторые из этих горутин вызывали ReadMessage, но застревали, поскольку также вызывалась Close.
Любая идея, как решить эту проблему?
Изменить: я использую confluent-kafka- go