Merge pull request #38 from kshpytsya/kafka-sasl-plain

 Add SASL/PLAIN config to kafka

README.md

@@ -62,7 +62,8 @@ session "" {
 
 ### Kafka
 
-To connect to Kafka with TLS, set the SINK_KAFKA_CA_CERT_PATH to the path to your CA cert file
+To connect to Kafka with TLS, set the SINK_KAFKA_CA_CERT_PATH to the path to your CA cert file.
+To use SASL/PLAIN authentication, set `$SINK_KAFKA_USER` and `$SINK_KAFKA_PASSWORD` environment variables.
 
 
 ## Usage

sink/kafka.go

@@ -70,6 +70,14 @@ func NewKafka() (*KafkaSink, error) {
 		config.Net.TLS.Enable = true
 	}
 
+	user := os.Getenv("SINK_KAFKA_USER")
+	if user != "" {
+		password := os.Getenv("SINK_KAFKA_PASSWORD")
+		config.Net.SASL.Enable = true
+		config.Net.SASL.User = user
+		config.Net.SASL.Password = password
+	}
+
 	producer, err := sarama.NewSyncProducer(brokerList, config)
 	if err != nil {
 		log.Fatal(err)