没有枚举常量org.apache.kafka.common.protocol.SecurityProtocol.CLIENTaws MSK

Question

我正在尝试在EC2上运行模式注册表，我的kafka正在AWS上运行。

这是我的属性文件

listeners=http://0.0.0.0:8081
kafkastore.connection.url=z-3.***:2181,z-***:2181,z-**:2181
kafkastore.bootstrap.servers=PLAINTEXT://b-3.**:9092,PLAINTEXT://b-6.**:9092,PLAINTEXT://b-1.**:9092
kafkastore.topic=_schemas
debug=false

schema-registry-start /etc/schema-registry/schema-registry.properties &

当我运行这个我得到下面的错误

kafka.common.KafkaException: Failed to parse the broker info from zookeeper: {"listener_security_protocol_map":{"CLIENT":"PLAINTEXT","CLIENT_SECURE":"SSL","REPLICATION":"PLAINTEXT","REPLICATION_SECURE":"SSL"},"endpoints"

Caused by: java.lang.IllegalArgumentException: No enum constant org.apache.kafka.common.protocol.SecurityProtocol.CLIENT

我已经改变了它TSL，明文和没有两者，但都是抛出错误。我也有从 EC2 到 MSK 的连接。

阿帕奇Kafka版

2.2.1

汇合

sudo rpm --import http://packages.confluent.io/deb/3.1/archive.key

即使我没有提到经纪人网址，我也会得到同样的错误

根据答案更新问题

当没有提到连接url时

[ec2-user@ip-10-97-54-99 ~]$ [2020-01-11 03:46:29,418] ERROR Server died unexpectedly:  (io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain:51)
io.confluent.common.config.ConfigException: Missing required configuration "kafkastore.connection.url" which has no default value.
        at io.confluent.common.config.ConfigDef.parse(ConfigDef.java:241)
        at io.confluent.common.config.AbstractConfig.<init>(AbstractConfig.java:76)
        at io.confluent.rest.RestConfig.<init>(RestConfig.java:299)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig.<init>(SchemaRegistryConfig.java:358)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig.<init>(SchemaRegistryConfig.java:354)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain.main(SchemaRegistryMain.java:41)

提到< code>CLIENT://或< code>CLIENT_SECURE://也会抛出相同的错误。

MSK也提供＜code＞明文

Answer 1

如果您配置＜code＞kafkastore.bootstrap。服务器，则需要从模式注册表中删除Zookeeper连接字符串。

基于Kafka的初选是在以下情况下选择的

试着先移除它。

也是相关的-https://github.com/confluentinc/schema-registry/issues?utf8=

不清楚你试图安装哪个版本的注册表，但是MSK没有任何明文客户端连接字符串，如< code > listener _ security _ protocol _ map 所示。

假设明文仍然不起作用，您需要为有效的侦听器协议指定不同的连接，例如< code>CLIENT://或< code>CLIENT_SECURE://

Answer 2

我认为问题在于你的版本。在我手动安装之后，我也遇到了同样的问题，它对我很有效。

这是我的确切安装步骤和模式注册表开始步骤

sudo yum install java-1.8.0
curl -O http://packages.confluent.io/archive/5.3/confluent-5.3.2-2.12.tar.gz
tar xzf confluent-5.3.2-2.12.tar.gz
cd confluent-5.3.2/etc/schema-registry/

/home/ec2-user/confluent-5.3.2/bin/schema-registry-start /home/ec2-user/confluent-5.3.2/etc/schema-registry/schema-registry.properties