Support SSL Encryption about goka HOT 4 CLOSED

Perfect this is exactly what I needed. Thanks @db7

from goka.

Goka does not implement the communication with Kafka. For that we employ existing libraries. By default, Goka uses sarama, which is pure Go and does support SSL connections.

As an alternative, you may also use confluent-kafka-go, which uses librdkafka underneath and should support virtually everything you'd need. Although our wrapper around confluent's library isn't complete yet, it shouldn't be too hard to finish it.

from goka.

I see that it's possible with sarama, but the question was more around whether goka will let me configure the TLS options passed to sarama?

It may be possible using goka.WithProducerBuilder() and goka.WithConsumerBuilder(), I'll have a play when I have time. If I get a decent example I'll post back here.

from goka.

Yes, you can configure sarama with the builders. Check this snippet for an example.

from goka.