时间戳

首页 > 解决方案 > 没有枚举常量 org.apache.kafka.common.protocol.SecurityProtocol.CLIENT aws MSK

apache-kafka - 没有枚举常量 org.apache.kafka.common.protocol.SecurityProtocol.CLIENT aws MSK

问题描述

我正在尝试在 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 ，PLAINTEXT 并且两者都没有，但都抛出错误。我也有从 EC2 到 MSK 的连接。

阿帕奇卡夫卡版本

2.2.1

汇合

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

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

根据答案更新问题

当没有提到连接网址时 

[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)

提到CLIENT://orCLIENT_SECURE://也会抛出同样的错误。

MSK 也提供Plaintext。我可以在客户信息中看到这一点

标签： apache-kafkaconfluent-schema-registryaws-msk

解决方案

我认为问题出在您的版本上。在我手动安装之后我也遇到了同样的问题，它对我有用。

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

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

推荐阅读