commit
cff6c7d201
@ -100,7 +100,7 @@ async def baidu_sms_kafka_consumer(ns={}):
|
|||||||
'security.protocol': 'SASL_SSL',
|
'security.protocol': 'SASL_SSL',
|
||||||
'ssl.endpoint.identification.algorithm': 'none',
|
'ssl.endpoint.identification.algorithm': 'none',
|
||||||
# 证书文件路径
|
# 证书文件路径
|
||||||
'ssl.ca.location': 'D:/Code/kboss/kgadget/src/baidu_kafka_ca.pem',
|
'ssl.ca.location': 'baidu_kafka_ca.pem',
|
||||||
# SASL 机制
|
# SASL 机制
|
||||||
'sasl.mechanism': 'SCRAM-SHA-512',
|
'sasl.mechanism': 'SCRAM-SHA-512',
|
||||||
# SASL 用户名
|
# SASL 用户名
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user