ホームページ

バックエンド開発

Golang

**Golang Kafka 10 でコンシューマグループオフセットを取得する方法**

Golang Kafka 10 でコンシューマグループオフセットを取得する方法

DDD

Oct 25, 2024 am 10:51 AM

**How to Get Consumer Group Offsets in Golang Kafka 10?**

Golang Kafka 10 でのコンシューマグループオフセットの取得

Kafka 10 の Golang の Kafka ライブラリ (Sarama) でのコンシューマグループサポートの導入により、開発者は、外部ライブラリに依存せずにコンシューマグループ関連の機能にアクセスできるようになりました。一般的なタスクの 1 つは、コンシューマグループによって処理されている現在のメッセージオフセットを取得することです。以前は、これには Kazoo-go などの Zookeeper ベースのソリューションを使用する必要がありました。 Sarama-cluster を使用すると、次のコードを通じてこれを実現できます:

<code class="go">package main

import (
    "context"
    "log"
    "strings"

    "github.com/Shopify/sarama"
)

func main() {
    groupName := "testgrp"
    topic := "topic_name"
    offset, err := GetCGOffset(context.Background(), "localhost:9092", groupName, topic)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Consumer group %s offset for topic %s is: %d", groupName, topic, offset)
}

type gcInfo struct {
    offset int64
}

func (g *gcInfo) Setup(sarama.ConsumerGroupSession) error {
    return nil
}

func (g *gcInfo) Cleanup(sarama.ConsumerGroupSession) error {
    return nil
}

func (g *gcInfo) ConsumeClaim(_ sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error {
    g.offset = claim.InitialOffset()
    return nil
}

func GetCGOffset(ctx context.Context, brokers, groupName, topic string) (int64, error) {
    config := sarama.NewConfig()
    config.Consumer.Offsets.AutoCommit.Enable = false // we're not going to update the consumer group offsets
    client, err := sarama.NewConsumerGroup(strings.Split(brokers, ","), groupName, config)
    if err != nil {
        return 0, err
    }
    info := gcInfo{}
    if err := client.Consume(ctx, []string{topic}, &info); err != nil {
        return 0, err
    }
    return info.offset, nil
}</code>

以上が**Golang Kafka 10 でコンシューマグループオフセットを取得する方法**の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

このウェブサイトの声明

この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

ホットAIツール

Undress AI Tool

脱衣画像を無料で

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

ArtGPT

Stock Market GPT

AIを活用した投資調査により賢明な意思決定を実現

ホットツール

メモ帳++7.3.1

使いやすく無料のコードエディター

SublimeText3 中国語版

中国語版、とても使いやすい

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

ドリームウィーバー CS6

ビジュアル Web 開発ツール

SublimeText3 Mac版

神レベルのコード編集ソフト（SublimeText3）

ホットトピック

Related knowledge

Golangで使用される空のstruct struct {}は何ですか Sep 18, 2025 am 05:47 AM

struct {}はgoのフィールドレス構造であり、ゼロバイトを占有し、データが不要なシナリオでよく使用されます。 Goroutine同期など、チャネル内の信号として使用されます。 2。効率的なメモリの重要な存在チェックを実現するために、値の種類のコレクションとして使用されます。 3.依存関係の注入または組織機能に適した定義可能なステートレスメソッドレシーバー。このタイプは、制御フローと明確な意図を表現するために広く使用されています。

Go WebSocketEOFエラー：接続をアクティブに保ちます Sep 16, 2025 pm 12:15 PM

この記事は、GOを使用してWebSocketを開発するときに遭遇するEOF（ファイルの終了）エラーを解決することを目的としています。通常、このエラーは、サーバーがクライアントメッセージを受信し、接続が予期せず閉じられている場合に発生し、その後のメッセージを正常に配信できません。この記事では、問題の原因を分析し、コードの例を提供し、対応するソリューションを提供して、開発者が安定した信頼できるWebSocketアプリケーションを構築できるようにします。

GOプログラムで外部エディターを開始し、それが完了するのを待ちます Sep 16, 2025 pm 12:21 PM

この記事では、GOプログラムで外部エディター（VIMやNanoなど）を開始し、プログラムが実行され続ける前にユーザーがエディターを閉じるのを待つ方法について説明します。 cmd.stdin、cmd.stdout、およびcmd.stderrを設定することにより、編集者は端末と対話して、起動の障害の問題を解決できます。同時に、完全なコードの例が表示され、開発者がこの機能をスムーズに実装するのに役立つ予防策が提供されます。

Golangでファイルをどのように読み取り、書き込みますか？ Sep 21, 2025 am 01:59 AM

Goprovidessimpleandefficientfilehandlingusingtheosandbufiopackages.Toreadasmallfileentirely,useos.ReadFile,whichloadsthecontentintomemorysafelyandautomaticallymanagesfileoperations.Forlargefilesorincrementalprocessing,bufio.Scannerallowsline-by-liner

Golang Webサーバーのコンテキストのミドルウェアは何ですか？ Sep 16, 2025 am 02:16 AM

ミドルウェアワーシングウェブシュアレーバーは、interceptttprequestSeyreatheyreachtheTheTheHandlerを使用して、カットカッティングの機能性を有効にします

Golangのファイルから構成を読み取る方法 Sep 18, 2025 am 05:26 AM

標準ライブラリのエンコード/JSONパッケージを使用して、JSON構成ファイルを読み取ります。 2。GOPKG.in/Yaml.v3ライブラリを使用して、YAML形式の構成を読み取ります。 3. os.getenvまたはgodotenvライブラリを使用して、ファイル構成を上書きします。 4. Viperライブラリを使用して、マルチフォーマット構成、環境変数、自動リロードなどの高度な機能をサポートします。タイプの安全性を確保し、ファイルと解析エラーを適切に処理し、構造タグマッピングフィールドを正しく使用し、ハードコーディングパスを避け、環境変数または生産環境での安全な構成ストレージを使用することをお勧めするために、構造を定義する必要があります。単純なJSONから始めて、要件が複雑な場合にViperに移行できます。

言語CFBモード暗号化を行う：XorkeyStreamのポインター例外を解決する Sep 16, 2025 pm 12:30 PM

この記事の目的は、開発者がAES暗号化にGO言語のCFB（CIPHERフィードバック）モードを使用するときに遭遇する可能性のあるXorkeyStream機能によって引き起こされるゼロのポインターの例外を理解し、解決するのを支援することです。エラーの一般的な原因を分析し、正しいコードの例を提供することにより、暗号化プロセスがスムーズに進むようにします。焦点は、初期化ベクトル（IV）の正しい使用と、AESブロックサイズを理解することの重要性にあります。

別のアーキテクチャ（アーム）に行く方法 Sep 16, 2025 am 12:27 AM

ARMアーキテクチャ用のGOコードをコンパイルするには、環境変数を設定してGoBuildコマンドを使用します。 1。ターゲットプラットフォームを指定するには、Goos = LinuxとLinuxとGoarch = ARM（32ビット）またはARM64（64ビット）を設定します。 2.オプションで、ARMV7命令セットを指定するには、32ビットアームのGOARM = 7を設定します。 3. CGOが不要な場合は、静的リンクを確保するためにCGO_ENABLED = 0を設定します。 4。Goos= LinuxGoarch = ARM64CGO_ENABLED = 0GOBUILD-OMYAPP-ARM64などのコマンドを実行して、バイナリファイルを生成します。 5。生成されたバイナリファイルをアームデバイスにコピーします（ラズバーなど

See all articles

**Golang Kafka 10 でコンシューマ グループ オフセットを取得する方法**