17 lines
450 B
Go
17 lines
450 B
Go
package kafka
|
|
|
|
import (
|
|
"cybertron/configs"
|
|
"github.com/confluentinc/confluent-kafka-go/v2/kafka"
|
|
)
|
|
|
|
func ConfluentProducer(baseConfig *configs.KafkaConfig) (*kafka.Producer, error) {
|
|
return kafka.NewProducer(&kafka.ConfigMap{
|
|
"bootstrap.servers": baseConfig.Brokers[0],
|
|
"security.protocol": "SASL_SSL",
|
|
"sasl.mechanisms": baseConfig.Mechanism,
|
|
"sasl.username": baseConfig.Username,
|
|
"sasl.password": baseConfig.Password,
|
|
})
|
|
}
|