How to pass security protocol, mechanism user and pass to connect to kafka

[raafael]

Hello! I didn't find in the docs more information about different kafka configurations to connect, I am using a bintami kafka helm deployed in k8s and my configuration to connect to the brooker in my microservices is like that:

kafka.bootstrap.servers=xxxxx
kafka.security.protocol=SASL_PLAINTEXT
kafka.sasl.mechanism=SCRAM-SHA-256
kafka.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="" password="";
kafka.session.timeout.ms=30000

Is possible to connect in kafka like this with krakend ?

[0xMattijs]

It looks like no config is passed to the underlying kafkapubsub constructor:

krakend-pubsub/client.go

Line 74 in 07b3583

t, err := pubsub.OpenTopic(ctx, dns+cfg.TopicURL)

It would be nice if settings from the extra config could be picked up and passed here, since this seems possible according to the docs: https://pkg.go.dev/gocloud.dev/pubsub/kafkapubsub#example-OpenTopic

Eventually the config will be passed to Sarama: https://pkg.go.dev/github.com/IBM/sarama#Config, which offers all the nice knobs.