/ Jun 27th, 2020 /

Kafka components support SASL

Vector has a new way to authenticate with Kafka!

The Kafka source and sink now support SASL authentication.

You can review the option in the component docs.

vector.toml
[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

This feature isn't yet supported on Windows.

This change was made available in 0.10.0. You can get this change by downloading the latest stable release.

Like What You See?