I wonder if statistics provided by librdkafka (available also with confluent-kafka-go) could have been used to solve the issue with less effort. https://github

I wonder if statistics provided by librdkafka (available also with confluent-kafka-go) could have been used to solve the issue with less effort. https://github.com/edenhill/librdkafka/blob/master/STATISTICS.md https://github.com/edenhill/librdkafka/blob/master/STATISTIC...