我是这样使用的kafka-console-producer.sh:
kafka-console-producer.sh --bootstrap-server $BTSTRP --topic test --producer.config client.properties
Run Code Online (Sandbox Code Playgroud)
它运行良好,没有警告或错误。在client.properties我有一些属性。示例文件的一部分:
security.protocol=SASL_SSL
sasl.mechanism=SCRAM-SHA-512
ssl.endpoint.identification.algorithm=
Run Code Online (Sandbox Code Playgroud)
然后我想使用下面的命令来列出使用相同的 SCRAM 用户,client.properties因为它匹配这里的所有内容:
kafka-configs.sh --bootstrap-server $BTSTRP --command-config client.properties --describe --entity-type users
Run Code Online (Sandbox Code Playgroud)
但它打印低于警告(不是完整输出)并且最终不起作用(只打印这些警告):
[2020-09-24 10:30:27,823] WARN The configuration 'ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-09-24 10:30:27,823] WARN The configuration 'ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-09-24 10:30:27,823] WARN The configuration 'ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-09-24 10:30:27,823] WARN The configuration 'ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-09-24 10:30:27,823] WARN The configuration 'ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-09-24 10:30:27,823] WARN The configuration 'ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
Run Code Online (Sandbox Code Playgroud)
问题:我应该如何格式化 Kafka 的管理客户端--command-config属性文件?我已经在这里通读了,但似乎没有任何帮助:
| 归档时间: |
|
| 查看次数: |
563 次 |
| 最近记录: |