Go-Client-Beispiel für Kafka-Consumer von Fusion Cloud mit sasl.username und sasl.password

php-Editor Baicao präsentiert Ihnen ein Go-Client-Beispiel über den Fusion Cloud Kafka-Consumer mit sasl.username und sasl.password. In diesem Beispiel zeigen wir, wie Sie mit der Programmiersprache Go einen Consumer-Client erstellen, der eine sichere Authentifizierung mit Fusion Cloud Kafka ermöglicht. Durch Festlegen der richtigen Parameter sasl.username und sasl.password können wir sicherstellen, dass der Client erfolgreich eine Verbindung herstellen und Nachrichten aus dem Kafka-Thema konsumieren kann. In diesem Beispiel werden die erforderlichen Bibliotheken und der Code detailliert beschrieben, damit Sie diese Funktionalität schnell verstehen und anwenden können. Lass uns einen Blick darauf werfen!

Frageninhalt

Hat jemand ein Go-Client-Beispiel eines Kafka-Konsumenten, der sasl.username und sasl.password verwendet?

Ich erhalte eine Fehlermeldung, wenn ich versuche, Nachrichten aus Fusion Cloud zu konsumieren.

Failed to connect to Kafka broker: kafka: client has run out of available brokers to talk to: EOF

Workaround

Confluence verfügt über ein eigenes Beispiel-Repository

https://github.com/confluenceinc/confluence-kafka-go/blob/master/examples/confluence_cloud_example/confluence_cloud_example.go

Auszug

bootstrapServers          = "<BOOTSTRAP_SERVERS>"
    ccloudAPIKey              = "<CCLOUD_API_KEY>"
    ccloudAPISecret           = "<CCLOUD_API_SECRET>"
    schemaRegistryAPIEndpoint = "<CCLOUD_SR_ENDPOINT>"
    schemaRegistryAPIKey      = "<CCLOUD_SR_API_KEY>"
    schemaRegistryAPISecret   = "<CCLOUD_SR_API_SECRET>"
)

func main() {

    topic := "go-test-topic"
    createTopic(topic)

    // Produce a new record to the topic...
    producer, err := kafka.NewProducer(&kafka.ConfigMap{
        "bootstrap.servers": bootstrapServers,
        "sasl.mechanisms":   "PLAIN",
        "security.protocol": "SASL_SSL",
        "sasl.username":     ccloudAPIKey,
        "sasl.password":     ccloudAPISecret})

    if err != nil {
        panic(fmt.Sprintf("Failed to create producer: %s", err))
    }

    client, err := schemaregistry.NewClient(schemaregistry.NewConfigWithAuthentication(
        schemaRegistryAPIEndpoint,
        schemaRegistryAPIKey,
        schemaRegistryAPISecret))

Das obige ist der detaillierte Inhalt vonGo-Client-Beispiel für Kafka-Consumer von Fusion Cloud mit sasl.username und sasl.password. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!