dtle
dtle copied to clipboard
kafka-Mysql job supports configuring kafka account passwords
看了下kafka go client, 有如下密码相关配置, 是指这个吗?
// SASL based authentication with broker. While there are multiple SASL authentication methods
// the current implementation is limited to plaintext (SASL/PLAIN) authentication
SASL struct {
// User is the authentication identity (authcid) to present for
// SASL/PLAIN or SASL/SCRAM authentication
User string
// Password for SASL/PLAIN authentication
Password string
// authz id used for SASL/SCRAM authentication
KafkaConfig增加了User和Password两个参数. 但不知Kafka那边如何配置, 未测试.