如何使用 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中文網其他相關文章！