在尝试将 kafkacat 与消息中心一起使用时,我使用了以下内容:
kafkacat -X client.id=xxxxx \
-X sasl.jaas.config='org.apache.kafka.common.security.plain.PlainLoginModule required username="xxxx" password="xxxx";' \
-X security.protocol=SASL_SSL \
-X sasl.mechanism=PLAIN \
-X ssl.protocol=TLSv1.2 \
-X ssl.enabled.protocols=TLSv1.2 \
-X ssl.truststore.type=JKS \
-X ssl.endpoint.identification.algorithm=HTTPS -b broker:port -C -t topic
Run Code Online (Sandbox Code Playgroud)
并得到以下错误:
% ERROR: Java JAAS configuration is not supported, see https://github.com/edenhill/librdkafka/wiki/Using-SASL-with-librdkafka for more information.
Run Code Online (Sandbox Code Playgroud)
如何使用 kerberos 和提供的凭据来创建正确的密钥,然后使用它们从主题中使用?