Brian Landers e0d30b75db Add SASL/SCAM support to Kafka transport. (#121) ...

This pull request adds the optional -transport.kafka.scram flag,
which tells the Kafka transport to use SASL/SCRAM for authentication.
This allows goflow2 to work with AWS Managed Service for Kafka (MSK)
which does not support SASL/PLAIN.

Co-authored-by: Brian Landers <brian.landers@meraki.net>
Co-authored-by: lspgn <lspgn@users.noreply.github.com>

2022-10-08 15:02:22 -07:00

..

file

…

kafka

Add SASL/SCAM support to Kafka transport. (#121)

2022-10-08 15:02:22 -07:00

transport.go

style: defer unlock when possible/not trivial

2021-09-23 10:01:24 +02:00