Wie verbinde ich Kafka mit einer Go -Anwendung?

Zu den wichtigsten Schritten für die Verbindung mit GO und die Verwendung von KAFKA gehört die Installation der KAFKA-GO-Bibliothek, das Schreiben von Produzenten zum Senden von Nachrichten, das Schreiben von Verbrauchern, um Nachrichten zu erhalten, und das Beachten auf gemeinsame Probleme. 1. Installieren Sie die KAFKA-GO-Bibliothek, um Abhängigkeiten über Go-Mods zu verwalten. 2. Erstellen Sie Produzenten, um Nachrichten mit Autoren an das angegebene Thema zu senden. 3.. Erstellen Sie Verbraucher, um Leser zu verwenden, um Nachrichten aus dem angegebenen Thema zu ziehen. 4. Achten Sie auf Details wie Broker -Adresse, Themenname, Einstellungen für Verbrauchergruppen und Leistungsstimmen.

Es ist nicht schwierig, die GO -Bewerbungen von Kafka zu verbinden und zu verwenden, aber einige Details müssen beachtet werden. Die GO-Community hat mehrere relativ reife Kafka-Kundenbibliotheken, die am häufigsten verwendeten sarama und kafka-go . Dieser Artikel wird sich auf kafka-go konzentrieren, da seine API moderner und go-style ist.

Das Folgende finden Sie einige wichtige Punkte, mit denen Sie schnell loslegen können.

Installieren Sie Kafka-Go

Der erste Schritt ist natürlich die Installation der Bibliothek. Sie können Go MOD verwenden, um Abhängigkeiten zu verwalten:

 Holen Sie sich github.com/segmentio/kafka-go

Nach Abschluss der Installation können Sie an Produzenten und Verbraucher schreiben.

Schreiben Sie einen einfachen Kafka -Produzenten

Der Produzent ist dafür verantwortlich, Nachrichten an das Thema Kafka zu senden. Der grundlegende Prozess besteht darin, einen Schriftsteller zu erstellen und dann Daten an das angegebene Thema zu schreiben.

 Paket Main

importieren (
    "Kontext"
    "fmt"
    "github.com/segmentio/kafka-go"
    "Zeit"
)

func main () {
    // Erstellen Sie einen Schriftsteller und stellen Sie eine Verbindung zum Kafka -Broker her
    Schriftsteller: = kafka.newwriter (Kafka.WriterConfig {
        Makler: [] String {"Localhost: 9092"},
        Thema: "my-topic",
        Balancer: & kafka.leastBytes {},
    })

    // eine Nachricht senden err: = writer.writemessages (context.background (),
        kafka.message {
            Schlüssel: [] byte ("key-a"),
            Wert: [] byte ("Hallo Welt"),
        },
    )
    Wenn er! = nil {
        Panik ("konnte keine Nachricht schreiben" err.Error ())
    }

    fmt.println ("Nachricht gesendet")
    writer.close ()
}

• Brokers sind die Adressliste der Kafka -Cluster.
• Topic ist das Zielthema.
• Balancer wird verwendet, um zu steuern, wie Nachrichten an Partitionen zugeordnet werden. LeastBytes ist eine relativ häufige Strategie.

Schreiben Sie einen einfachen Kafka -Verbraucher

Der Verbraucher ist dafür verantwortlich, Nachrichten von Kafka zu ziehen. Sie müssen das Thema und die Gruppe angeben, um sie zu konsumieren.

 Paket Main

importieren (
    "Kontext"
    "fmt"
    "github.com/segmentio/kafka-go"
    "Zeit"
)

func main () {
    Leser: = kafka.newreader (kafka.reaceconfig {
        Makler: [] String {"Localhost: 9092"},
        Thema: "my-topic",
        Groupid: "My-Group",
        Startoffset: Kafka.Firstoffset,
    })

    für {
        msg, err: = reader.readMessage (context.background ())
        Wenn er! = nil {
            Panik ("Fehler beim Lesen von Meldungen:" err.Error ())
        }
        fmt.printf ("erhalten: %s \ n", String (msg.value))
    }

    reader.close ()
}

• GroupID wird für Verbrauchergruppen verwendet, und mehrere Verbraucher können eine Gruppe teilen, um Lastausgleich zu erzielen.
• StartOffset bestimmt, wo der Konsum beginnt, und FirstOffset bedeutet, von vorne zu beginnen.

Häufig gestellte Fragen und Notizen

• Kannst du dich nicht mit Kafka verbinden?
  Überprüfen Sie, ob die Broker -Adresse von Kafka korrekt ist und ob die Firewall Port 9092 veröffentlicht hat.

• Verbraucher können die Nachrichten nicht erhalten?
  Überprüfen Sie, ob der Themenname korrekt ist, ob Kafka eine Nachricht geschrieben hat und ob die Verbrauchergruppe konflikt.

• Vorschläge zur Leistungsabstimmung:

  • Durch das Senden von Nachrichten in Chargen können die Leistung der Produzenten verbessert werden.
  • Verbraucher können MaxWait für die Steuerung der Zugfrequenz einstellen.
  • Stellen Sie die Anzahl der Partitionen und Verbraucher vernünftigerweise fest, um Ressourcenverschwendung zu vermeiden.

• Nachrichtenbestätigungsmechanismus:

  • Kafka ist asynchron, um standardmäßig Offsets einzureichen, die manuell über reader.SetOffset() kontrolliert werden können.
  • Wenn Sie den Zeitpunkt der Offset -Einreichung genau kontrollieren möchten, können Sie ihn nach dem Verzehr der Nachricht manuell einreichen.

Grundsätzlich ist das. GO ist Kafka nicht kompliziert, aber Sie sollten auf Konfigurationsdetails und Laufzeit -Ausnahmeberechnung achten. Wenn Sie es gerade erst verwenden, wird empfohlen, mit einfachen Beispielen zu beginnen und dann nach und nach Wiederholung, Protokollierung, Überwachung und andere Mechanismen hinzuzufügen.

Das obige ist der detaillierte Inhalt vonWie verbinde ich Kafka mit einer Go -Anwendung?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!