Es kann keine Verbindung zu Confluence Kafka über kafka-go von segmentio hergestellt werden

Frageninhalt

Ich kann Confluence CLI verwenden, um eine Verbindung zum Confluence Kafka-Cluster herzustellen, aber ich kann die Kafka-Go-Bibliothek von Segmentio nicht verwenden. Ich erhalte die folgende Fehlermeldung.

with SASL: SASL handshake failed: EOF

Das ist meine Funktion in go

package consumer

import (
    "context"
    "fmt"
    "log"
    "os"
    "time"

    "github.com/segmentio/kafka-go"
    "github.com/segmentio/kafka-go/sasl/plain"
)
func Consume(ctx context.Context) {
    // create a new logger that outputs to stdout
    // and has the `kafka reader` prefix
    l := log.New(os.Stdout, "kafka reader: ", 0)
    mechanism := plain.Mechanism{
        Username: "my-api-key",
        Password: "my-api-secret",
    }

    dialer := &kafka.Dialer{
        Timeout:       10 * time.Second,
        DualStack:     true,
        SASLMechanism: mechanism,
    }

    r := kafka.NewReader(kafka.ReaderConfig{
        Brokers: []string{brokerAddress}, // brokerAddress given in confluent cloud cluster settings. 
        Topic:   []string{"steps"}[0],
        // assign the logger to the reader
        Logger: l,
        Dialer: dialer,
    })
    for {
        // the `ReadMessage` method blocks until we receive the next event
        msg, err := r.ReadMessage(ctx)
        if err != nil {
            panic("could not read message " + err.Error())
        }
        // after receiving the message, log its value
        fmt.Println("received: ", string(msg.Value))
    }
}

Ich habe versucht, neue Schlüssel zu generieren, indem ich den Benutzernamen und das Passwort meines Kontos verwendet und die Partitionen reduziert habe, aber nichts hat funktioniert.

Richtige Antwort

Es scheint, dass Ihr Server TLS 版本不被接受，您可以使用 MinVersion Go-Kafka dazu zwingt, es zu akzeptieren:

dialer := &kafka.Dialer{
        Timeout:       10 * time.Second,
        DualStack:     true,
        SASLMechanism: mechanism,
        TLS: &tls.Config{
            MinVersion: tls.VersionTLS12,
        },
    }

Das obige ist der detaillierte Inhalt vonEs kann keine Verbindung zu Confluence Kafka über kafka-go von segmentio hergestellt werden. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!