How kq.NewPusher sets the access username and password for Kafa

[bCoder778]

When I added a password to Kafa's access, the creation of the pusher did not find the parameter to set the password, resulting in the pusher not working. I want to know where to set the password for access

[ljluestc]

package main

import (
    "github.com/Shopify/sarama"
    // Assuming kq is your package which includes NewPusher
    "kq"
)

func main() {
    // Configuration for Kafka
    config := sarama.NewConfig()
    config.Net.SASL.Enable = true
    config.Net.SASL.User = "your_username"
    config.Net.SASL.Password = "your_password"
    config.Net.SASL.Mechanism = sarama.SASLTypePlaintext // Use PLAIN mechanism, adjust as necessary

    // Broker addresses
    brokers := []string{"localhost:9092"}

    // Create a new client with the configured settings
    client, err := sarama.NewClient(brokers, config)
    if err != nil {
        panic(err)
    }
    defer client.Close()

    // Assuming NewPusher takes a client or configuration. Adjust according to actual function signature:
    pusher, err := kq.NewPusher(client)
    if err != nil {
        panic(err)
    }
    // Use your pusher
}