java - 使用启用了 TLS 的 kafka-topics cli 命令时出现问题

标签 java ssl apache-kafka

我正在使用最新的 landoop/fast-data-dev 镜像(但 Kafka cli 工具与上游相同)

在容器内尝试此命令时:

root@fast-data-dev / $ ./opt/landoop/kafka/bin/kafka-topics --bootstrap-server hostname:9093 --command-config client.properties -list

我收到此错误

[2020-11-26 18:09:01,580] WARN The configuration 'ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) 
[2020-11-26 18:09:01,581] WARN The configuration 'ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) 
[2020-11-26 18:09:01,582] WARN The configuration 'ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) 
[2020-11-26 18:09:01,582] WARN The configuration 'ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

这是我的 client.properties 文件

security.protocol=SSL
ssl.truststore.location=/data/cluster-crt/ca.p12
ssl.truststore.password=valid_password
ssl.keystore.location=/data/user-crt/user.p12
ssl.keystore.password=valid_pasword

我做错了什么吗? 谢谢

最佳答案

我认为这与这个已知问题有关,但管理客户端无论如何都应该可以工作。

https://issues.apache.org/jira/browse/KAFKA-10566

还有一个 PR 可以修复它。

https://github.com/apache/kafka/pull/9365

关于java - 使用启用了 TLS 的 kafka-topics cli 命令时出现问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/65027395/

相关文章:

java - 在 Maven 项目中找不到 ImmutableMap

java - 如何在不使用 setter 的情况下从子类访问父类(super class)中的私有(private)字段?

php - 如何在 Zend MVC 中实现 SSL

azure - 如何使用 Azure Function V2 管理签名证书

java - 使用 Storm Topology 从 Kafka 队列消费数据

bash - kafka-console-producer 和 bash 脚本

java - java中从多个表检索数据时的最佳设计原则

java - 设置 JButton 的默认焦点

security - 从命令行确定 TLS/SSL 证书是否为 'trusted'?

apache-kafka - 出现错误 :Batch containing 3 record(s) expired due to timeout while requesting metadata from brokers for test2R2P2-1