代理在启动时失败,我可以看到以下错误:
INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
ERROR ClassNotFoundException exception occurred: io.confluent.kafka.security.config.provider.SecurePassConfigProvider (kafka.server.KafkaConfig)
INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
ERROR ClassNotFoundException exception occurred: io.confluent.kafka.security.config.provider.SecurePassConfigProvider (kafka.server.KafkaConfig)
INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
ERROR ClassNotFoundException exception occurred: io.confluent.kafka.security.config.provider.SecurePassConfigProvider (kafka.server.KafkaConfig)
INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
ERROR ClassNotFoundException exception occurred: io.confluent.kafka.security.config.provider.SecurePassConfigProvider (kafka.server.KafkaConfig)
INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
INFO KafkaConfig values:
----------------------------
我在server.properties
文件中对其中一个属性(即server.properties
)进行了秘密设置,并尝试重新启动服务器并观察到上述错误。
任何帮助都将不胜感激。谢谢!
---server.properties---
##
ssl.truststore.password = ${securepass:/home/secret/secrets.txt:server.properties/ssl.truststore.password}
config.providers = securepass
config.providers.securepass.class = io.confluent.kafka.security.config.provider.SecurePassConfigProvider
Confluent Community version used - 5.5.2
发布于 2022-01-14 17:22:18
汇合平台5.5.2的社区版与本课程无关.
$ find ./confluent-5.5.2 -name 'kafka-client-plugins*.jar'
在这里下载该文件,并确保它位于Kafka类路径中,例如,如果/usr/share/java/kafka
直接安装到操作系统上,或者安装在Confluent的share/java/kafka
文件夹中。
用
$ jar -tf kafka-client-plugins-5.5.2-ce.jar| grep SecurePassConfigProvider
io/confluent/kafka/security/config/provider/SecurePassConfigProvider.class
总的来说,如果有人对您的代理拥有文件系统访问权限,则您有更大的问题,而直接引用另一个文件来模糊该文件并不是“安全的”。
https://stackoverflow.com/questions/70706305
复制相似问题