如何从头订阅

Question

我正在尝试使用 GroupId 编写一个 Kafka Consumer foo，它订阅某个主题并从头开始读取（即使之前有偏移量）。我尝试与重新平衡回调一起使用Subscribe，但它似乎从未被调用（已设置设置go.application）。

有什么例子可以使这项工作成功吗？