auth

type SASLConfig ¶

type SASLConfig struct {
	Mechanism SASLMechanism
	Username  string
	Password  string
}

SASLConfig holds Kafka SASL authentication settings. Used with the KafkaSASL (source) and KafkaSinkSASL (sink) options.

type SASLMechanism ¶

type SASLMechanism string

SASLMechanism identifies a Kafka SASL authentication mechanism.

const (
	SASLPlain       SASLMechanism = "PLAIN"
	SASLScramSHA256 SASLMechanism = "SCRAM-SHA-256"
	SASLScramSHA512 SASLMechanism = "SCRAM-SHA-512"
)

type TLSConfig ¶

type TLSConfig struct {
	CertFile           string
	KeyFile            string
	CAFile             string
	InsecureSkipVerify bool
}

TLSConfig holds Kafka TLS settings.

If CertFile and KeyFile are both set, client certificates are loaded for mutual TLS. If CAFile is set, it is added to the root CAs used to verify the broker. InsecureSkipVerify disables certificate verification (for development only).