Contoh pelanggan Go untuk pengguna kafka Fusion Cloud dengan sasl.username dan sasl.password

editor php Baicao membawakan anda contoh pelanggan Go tentang pengguna Fusion Cloud Kafka dengan sasl.username dan sasl.password. Dalam contoh ini, kami akan menunjukkan cara menggunakan bahasa pengaturcaraan Go untuk mencipta pelanggan pengguna yang mampu mengesahkan pengesahan selamat dengan Fusion Cloud Kafka. Dengan menetapkan parameter sasl.username dan sasl.password yang betul, kami boleh memastikan pelanggan berjaya menyambung dan menggunakan mesej daripada topik Kafka. Contoh ini memperincikan perpustakaan dan kod yang diperlukan untuk membantu anda memahami dan menggunakan fungsi ini dengan cepat. Mari lihat!

Kandungan soalan

Adakah sesiapa mempunyai contoh pelanggan go bagi pengguna kafka menggunakan sasl.username dan sasl.password?

Saya mendapat ralat semasa cuba menggunakan mesej daripada Fusion Cloud.

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

Penyelesaian

confluence mempunyai repositori sampel sendiri

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

Petikan

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

Atas ialah kandungan terperinci Contoh pelanggan Go untuk pengguna kafka Fusion Cloud dengan sasl.username dan sasl.password. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!