有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

kafka connect无法启动(原因:java.lang.SecurityException)

试图在我的macOS中安装confluent平台(11.2.3) 但是connect无法启动。我正在使用Java8更新281。 按照this stackoverflow的建议回答,但没有运气

Starting ZooKeeper
ZooKeeper is [UP]
Starting Kafka
Kafka is [UP]
Starting Schema Registry
Schema Registry is [UP]
Starting Kafka REST
Kafka REST is [UP]
Starting Connect
Error: Connect failed to start

登录connect时出错。日志:

[2021-04-05 23:47:40,486] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed:85)
java.lang.ExceptionInInitializerError
    at javax.crypto.KeyGenerator.nextSpi(KeyGenerator.java:340)
    at javax.crypto.KeyGenerator.<init>(KeyGenerator.java:168)
    at javax.crypto.KeyGenerator.getInstance(KeyGenerator.java:223)
    at org.apache.kafka.connect.runtime.distributed.DistributedConfig.validateKeyAlgorithm(DistributedConfig.java:502)
    at org.apache.kafka.connect.runtime.distributed.DistributedConfig.lambda$configDef$2(DistributedConfig.java:375)
    at org.apache.kafka.common.config.ConfigDef$LambdaValidator.ensureValid(ConfigDef.java:1038)
    at org.apache.kafka.common.config.ConfigDef$ConfigKey.<init>(ConfigDef.java:1159)
    at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:152)
    at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:172)
    at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:211)
    at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:373)
    at org.apache.kafka.connect.runtime.distributed.DistributedConfig.configDef(DistributedConfig.java:371)
    at org.apache.kafka.connect.runtime.distributed.DistributedConfig.<clinit>(DistributedConfig.java:196)
    at org.apache.kafka.connect.cli.ConnectDistributed.startConnect(ConnectDistributed.java:94)
    at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:79)
Caused by: java.lang.SecurityException: Can not initialize cryptographic mechanism
    at javax.crypto.JceSecurity.<clinit>(JceSecurity.java:93)
    ... 15 more
Caused by: java.lang.SecurityException: The jurisdiction policy files are not signed by the expected signer! (Policy files are specific per major JDK release.Ensure the correct version is installed.)
    at javax.crypto.JarVerifier.verifyPolicySigned(JarVerifier.java:336)
    at javax.crypto.JceSecurity.loadPolicies(JceSecurity.java:378)
    at javax.crypto.JceSecurity.setupJurisdictionPolicies(JceSecurity.java:323)
    at javax.crypto.JceSecurity.access$000(JceSecurity.java:50)
    at javax.crypto.JceSecurity$1.run(JceSecurity.java:85)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.crypto.JceSecurity.<clinit>(JceSecurity.java:82)
    ... 15 more

共 (0) 个答案