如何使用 Sarama 檢索 Golang Kafka 10 中的消費者群組偏移量？
訪問Golang Kafka 10 中的消費者群組偏移
Golang Kafka 庫（sarama）與Kafka 10 的演變引入了本機消費者組功能。這就提出瞭如何檢索消費者群組正在處理的當前訊息偏移量的問題。
解決方案：
為了解決這個需求，sarama 庫提供了一種機制用於存取消費者群組偏移量。以下程式碼片段示範如何使用 GetCGOffset() 取得偏移量：
<code class="go">import (
"context"
"fmt"
"strings"
"github.com/Shopify/sarama"
)
func GetCGOffset(ctx context.Context, brokers, groupName, topic string) (int64, error) {
config := sarama.NewConfig()
config.Consumer.Offsets.AutoCommit.Enable = false
client, err := sarama.NewConsumerGroup(strings.Split(brokers, ","), groupName, config)
if err != nil {
return 0, err
}
defer client.Close()
info := gcInfo{}
if err := client.Consume(ctx, []string{topic}, &info); err != nil {
return 0, err
}
return info.offset, nil
}</code>
此程式碼建立一個消費者群組並連接到指定的代理程式。它會停用自動提交以確保偏移量在檢索過程中不會更新。 gcInfo 結構體追蹤初始偏移量，該偏移量代表消費者群組目前正在處理的訊息偏移量。
透過使用此機制，開發人員可以輕鬆檢查和管理其消費者群組的偏移量，從而能夠更精細地控制訊息處理和追蹤。
以上是如何使用 Sarama 檢索 Golang Kafka 10 中的消費者群組偏移量？的詳細內容。更多資訊請關注PHP中文網其他相關文章！
熱AI工具
Undress AI Tool
免費脫衣圖片
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Stock Market GPT
人工智慧支援投資研究，做出更明智的決策
熱門文章
熱工具
記事本++7.3.1
好用且免費的程式碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
強大的PHP整合開發環境
Dreamweaver CS6
視覺化網頁開發工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
Go 接口：非強制實現下的必要性
Sep 09, 2025 am 11:09 AM
Go 語言的接口雖然不強制類型顯式聲明實現，但它們在實現多態和代碼解耦方面仍然至關重要。通過定義一組方法簽名，接口允許不同的類型以統一的方式進行處理，從而實現靈活的代碼設計和可擴展性。本文將深入探討 Go 接口的特性，並通過示例展示其在實際開發中的應用價值。
如何確定 Go 構建過程中參與編譯的文件？
Sep 09, 2025 am 11:57 AM
本文旨在幫助開發者了解如何在 Go 項目中確定哪些文件會被編譯和鏈接，尤其是在存在特定於系統的文件時。我們將探討兩種方法：使用 go build -n 命令解析輸出，以及利用 go/build 包的 Import 函數。通過這些方法，您可以清晰地了解構建過程，並更好地管理您的項目。
您如何在Golang讀寫文件？
Sep 21, 2025 am 01:59 AM
Goprovidessimpleandefficientfilehandlingusingtheosandbufiopackages.Toreadasmallfileentirely,useos.ReadFile,whichloadsthecontentintomemorysafelyandautomaticallymanagesfileoperations.Forlargefilesorincrementalprocessing,bufio.Scannerallowsline-by-liner
在 Go 程序中啟動外部編輯器並等待其完成
Sep 16, 2025 pm 12:21 PM
本文介紹瞭如何在 Go 程序中啟動外部編輯器（如 Vim 或 Nano），並等待用戶關閉編輯器後，程序繼續執行。通過設置 cmd.Stdin、cmd.Stdout 和 cmd.Stderr，使得編輯器能夠與終端進行交互，從而解決啟動失敗的問題。同時，展示了完整的代碼示例，並提供了注意事項，幫助開發者順利實現該功能。
Golang中使用的空結構{}是什麼
Sep 18, 2025 am 05:47 AM
struct{}是Go中無字段的結構體，佔用零字節，常用於無需數據傳遞的場景。它在通道中作信號使用，如goroutine同步；2.用作map的值類型模擬集合，實現高效內存的鍵存在性檢查；3.可定義無狀態的方法接收器，適用於依賴注入或組織函數。該類型廣泛用於表達控制流與清晰意圖。
解決 Go WebSocket EOF 錯誤：保持連接活躍
Sep 16, 2025 pm 12:15 PM
本文旨在解決在使用 Go 語言進行 WebSocket 開發時遇到的 EOF (End-of-File) 錯誤。該錯誤通常發生在服務端接收到客戶端消息後，連接意外關閉，導致後續消息無法正常傳遞。本文將通過分析問題原因，提供代碼示例，並給出相應的解決方案，幫助開發者構建穩定可靠的 WebSocket 應用。
Golang Web服務器上下文中的中間件是什麼？
Sep 16, 2025 am 02:16 AM
MiddlewareinGowebserversarefunctionsthatinterceptHTTPrequestsbeforetheyreachthehandler,enablingreusablecross-cuttingfunctionality;theyworkbywrappinghandlerstoaddpre-andpost-processinglogicsuchaslogging,authentication,CORS,orerrorrecovery,andcanbechai
如何從Golang中的文件中讀取配置
Sep 18, 2025 am 05:26 AM
使用標準庫的encoding/json包讀取JSON配置文件；2.使用gopkg.in/yaml.v3庫讀取YAML格式配置；3.結合os.Getenv或godotenv庫使用環境變量覆蓋文件配置；4.使用Viper庫支持多格式配置、環境變量、自動重載等高級功能；必須定義結構體保證類型安全，妥善處理文件和解析錯誤，正確使用結構體標籤映射字段，避免硬編碼路徑，生產環境推薦使用環境變量或安全配置存儲，可從簡單的JSON開始，需求復雜時遷移到Viper。
