具有 sasl.username 和 sasl.password 的融合雲的 kafka 消費者的 go 用戶端範例

php小編草為您帶來了一個關於具有sasl.username和sasl.password的融合雲端Kafka消費者的Go客戶端範例。在這個範例中，我們將展示如何使用Go程式語言建立一個能夠與融合雲端Kafka進行安全認證的消費者用戶端。透過設定正確的sasl.username和sasl.password參數，我們可以確保客戶端能夠成功連線並消費Kafka主題中的訊息。這個範例將詳細介紹所需的程式庫和程式碼，幫助您快速理解和應用此功能。讓我們一起來看看吧！

問題內容

有人有一個使用 sasl.username 和 sasl.password 的 kafka 消費者的 go 客戶端範例嗎？

我在嘗試使用來自融合雲的訊息時遇到錯誤。

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

解決方法

confluence 有自己的範例儲存庫

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

#摘錄

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

以上是具有 sasl.username 和 sasl.password 的融合雲的 kafka 消費者的 go 用戶端範例的詳細內容。更多資訊請關注PHP中文網其他相關文章！