我正在嘗試使用 GroupId 編寫一個(gè) Kafka Consumer foo，它訂閱某個(gè)主題并從頭開始讀取（即使之前有偏移量）。我嘗試與重新平衡回調(diào)一起使用Subscribe，但它似乎從未被調(diào)用（已設(shè)置設(shè)置go.application）。有什么例子可以使這項(xiàng)工作成功嗎？