Merge pull request #71 from arquivei/feature/add-plaintext-authentica…

…tion-option Adds plaintext authentication option
arquivei · Jun 15, 2023 · 61e0b21 · 61e0b21
2 parents fa9767b + c76d83a
commit 61e0b21
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/pipeline/inputstreams/kafka_options.go b/pipeline/inputstreams/kafka_options.go
@@ -52,6 +52,16 @@ func WithKafkaSaslPlainAuthentication(username, password string) KafkaOption {
 	}
 }
 
+// WithKafkaPlaintextAuthentication configures kafka plaintext authentication.
+func WithKafkaPlaintextAuthentication(username, password string) KafkaOption {
+	return func(kp *kafkaProvider) {
+		kp.configMap["security.protocol"] = "PLAINTEXT"
+		kp.configMap["sasl.mechanisms"] = "PLAIN"
+		kp.configMap["sasl.username"] = username
+		kp.configMap["sasl.password"] = password
+	}
+}
+
 // WithKafkaBrokers sets the kafka topics for the input stream.
 func WithKafkaBrokers(brokers ...string) KafkaOption {
 	return func(kp *kafkaProvider) {