我正在尝试在 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
。我可以在客户信息中看到这一点