Go exemple de client pour le consommateur kafka de Fusion Cloud avec sasl.username et sasl.password

l'éditeur php Baicao vous propose un exemple de client Go sur le consommateur Fusion Cloud Kafka avec sasl.username et sasl.password. Dans cet exemple, nous montrerons comment utiliser le langage de programmation Go pour créer un client grand public capable d'une authentification sécurisée avec Fusion Cloud Kafka. En définissant les paramètres sasl.username et sasl.password corrects, nous pouvons garantir que le client peut se connecter et consommer avec succès les messages du sujet Kafka. Cet exemple détaille les bibliothèques et le code requis pour vous aider à comprendre et à appliquer rapidement cette fonctionnalité. Nous allons jeter un coup d'oeil!

Contenu de la question

Quelqu'un a-t-il un exemple de client Go d'un consommateur kafka utilisant sasl.username et sasl.password ?

Je reçois une erreur lorsque j'essaie de consommer des messages de Fusion Cloud.

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

Solution de contournement

confluence a son propre référentiel d'échantillons

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

Extrait

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))

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!