Flink CDC中sink到kafka，kafka有密码怎么处理？密码参数是啥？

在 Flink CDC 中，可以将数据 Sink 到 Kafka，并且可以通过指定参数配置 Kafka 密码。

• bootstrap.servers：配置 Kafka 的 Broker 地址，形如 'localhost:9092'。
• security.protocol：配置 Kafka 的加密协议，如 'PLAINTEXT', 'SSL' 或 'SASL_SSL'。
• sasl.mechanism：配置 SASL 模式，如 'SCRAM-SHA-256'。
• sasl.jaas.config：如果使用 SASL，则需要配置 JAAS 配置文件，形如 'org.apache.kafka.common.security.scram.ScramLoginModule required username="username" password="password";'。
• ssl.keystore.location：如果使用 SSL，则需要配置 keystore 文件位置。

'properties.security.protocol' = 'SASL_PLAINTEXT', 'properties.sasl.mechanism' = 'SCRAM-SHA-256', 'properties.sasl.jaas.config' = 'org.apache.kafka.common.security.scram.ScramLoginModule required username="uasername" password="password";'，此回答整理自钉群“Flink CDC 社区”