我正在尝试使用 GroupId 编写一个 Kafka Consumer foo，它订阅某个主题并从头开始读取（即使之前有偏移量）。我尝试与重新平衡回调一起使用Subscribe，但它似乎从未被调用（已设置设置go.application）。有什么例子可以使这项工作成功吗？
目前暂无任何回答
- 0 回答
- 0 关注
- 86 浏览
添加回答
举报
0/150
提交
取消
已解决430363个问题，去搜搜看，总会有你想问的