actiontech / dtle

Distributed Data Transfer Service for MySQL
https://actiontech.github.io/dtle-docs-cn
Mozilla Public License 2.0
551 stars 133 forks source link

kafka-Mysql job supports configuring kafka account passwords #968

Open asiroliu opened 2 years ago

ghost commented 2 years ago

看了下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
ghost commented 2 years ago

KafkaConfig增加了User和Password两个参数. 但不知Kafka那边如何配置, 未测试.