INFO-kafka SASL_SSL认证sql任务使用说明

适用模块

具体说明

使用示例

实时上传文件类型有限，先将.jks等文件转成平台支持的格式，如：客户端密钥库（原client.jks → 改名为client.keytab）
'properties.security.protocol' = 'SASL_SSL',
'properties.ssl.endpoint.identification.algorithm' = '',
'properties.sasl.mechanism' = 'PLAIN',
'properties.ssl.truststore.location' = 'zz_sloth/keytab md5值',
'properties.sasl.jaas.config' ='org.apache.kafka.common.security.scram.ScramLoginModule required username="xxx" password="xxx";'

作者：魏璐璐