我正在嘗試使用 GroupId 編寫一個 Kafka Consumer foo，它訂閱某個主題并從頭開始讀?。词怪坝衅屏浚Ｎ覈L試與重新平衡回調一起使用Subscribe，但它似乎從未被調用（已設置設置go.application）。有什么例子可以使這項工作成功嗎？