I’m using Apache Kafka(aws msk) with the IBM Sarama Go library to manage a Kafka consumer group. I’ve encountered an issue where my consumers stop consuming messages under certain conditions, even though they still seem to fetch topic metadata.