我是 Kafka 新手，有一个用例，我将从 Kafka 主题中读取数据。 读取时可能会添加新分区。有没有办法使用 golang
Sarama检测此问题的一种方法是定期列出主题。
您是否看到
Sarama如果将分区添加到“正在运行”的主题，则订阅该主题的任何现有消费者组都将重新平衡。 Sarama 客户端的文档对此主题有这样的说法 [原文如此]：
请注意，Sarama 的 Consumer 实现目前不支持自动消费者组重新平衡和偏移跟踪。 块引用
q.v.：https://pkg.go.dev/github.com/shopify/sarama
如果您确实需要响应重新平衡事件，那么您可能需要考虑切换到替代客户端，例如 Confluence。
fwiw，使用了 Sarama 后，Confluence 客户端（恕我直言，ime）更容易使用，并且功能更普遍、更全面。