Kafka components support SASL - Vector

The Kafka source and sink now support SASL authentication.

You can review the option in the component docs.

diff

  [sources.source0]
    type = "kafka" # required
    inputs = ["..."] # required
    bootstrap_servers = "10.14.22.123:9092,10.14.23.332:9092" # required
    group_id = "consumer-group-name" # required
    key_field = "message_key" # optional, no default
    topics = ["^(prefix1|prefix2)-.+", "topic-1", "topic-2"] # required
+   sasl.enabled = true # optional, default false
+   sasl.mechanism = "SCRAM-SHA-512" # optional, no default
+   sasl.password = "password" # optional, no default
+   sasl.username = "username" # optional, no default

{{< warning >}} This feature isn't yet supported on Windows. {{< /warning >}}