Heim  >  Artikel  >  Backend-Entwicklung  >  Wie kann ich mit Kafka 10 Verbrauchergruppen-Offsets in Go abrufen?

Wie kann ich mit Kafka 10 Verbrauchergruppen-Offsets in Go abrufen?

Barbara Streisand
Barbara StreisandOriginal
2024-10-30 06:17:02715Durchsuche

How to Retrieve Consumer Group Offsets in Go with Kafka 10?

Abrufen von Verbrauchergruppen-Offsets in Go mit Kafka 10

Mit der Veröffentlichung von Kafka 10 stellt die Go-Kafka-Bibliothek (sarama) jetzt Verbraucher bereit Gruppenfunktionen, ohne auf externe Bibliotheken angewiesen zu sein. Dies wirft die Frage auf, wie der aktuelle Nachrichten-Offset abgerufen werden kann, der von einer Verbrauchergruppe verarbeitet wird.

Lösung

Um den Verbrauchergruppen-Offset zu erhalten, führen Sie die folgenden Schritte aus:

  1. Implementieren Sie eine Verbrauchergruppen-Infostruktur:

    <code class="go">type gcInfo struct {
        offset int64
    }</code>
  2. Erstellen Sie einen Verbrauchergruppen-Info-Handler:

    <code class="go">func (g *gcInfo) ConsumeClaim(_ sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error {
        g.offset = claim.InitialOffset()
        return nil
    }</code>
  3. Konfigurieren und erstellen Sie die Verbrauchergruppe:

    <code class="go">config := sarama.NewConfig()
    config.Consumer.Offsets.AutoCommit.Enable = false
    client, err := sarama.NewConsumerGroup(strings.Split(brokers, ","), groupName, config)</code>
  4. Verbrauchen Sie a Nachricht innerhalb der Gruppe:

    <code class="go">info := gcInfo{}
    if err := client.Consume(ctx, []string{topic}, &amp;info); err != nil {
        return 0, err
    }</code>
  5. Versatz abrufen:

    <code class="go">return info.offset, nil</code>

Damit Implementierung können Sie jederzeit den Consumer-Gruppen-Offset für eine bestimmte Partition und ein bestimmtes Thema abrufen.

Das obige ist der detaillierte Inhalt vonWie kann ich mit Kafka 10 Verbrauchergruppen-Offsets in Go abrufen?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn