将模式注册Docker容器连接到AWS MSK

Question

我无法将模式注册表连接到MSK。我在一个单独的实例中运行Docker，并启用了到MSK服务的连接。

尝试了confluent docker.io/confluentinc/cp模式注册表中的docker映像：最新。

docker run -d \
--net=host 
--name=schema-registry 
-e SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL=10.95.21.38:2181 
-e SCHEMA_REGISTRY_HOST_NAME=schema-registry 
-e SCHEMA_REGISTRY_LISTENERS=
http://schema-registry:8081 
-e SCHEMA_REGISTRY_DEBUG=true 
docker.io/confluentinc/cp-schema-registry:latest

使用低于以下SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL连接时遇到的错误

[main] ERROR io.confluent.admin.utils.cli.KafkaReadyCommand - Error while running kafka-ready.
java.lang.RuntimeException: No endpoints found for security protocol [PLAINTEXT]. Endpoints found in ZK [{REPLICATION=b-1-internal.kafkaclusternew.jbf0pp.c4.kafka.us-west-2.amazonaws.com:9093, CLIENT=b-1.kafkaclusternew.jbf0pp.c4.kafka.us-west-2.amazonaws.com:9092, CLIENT_SECURE=b-1.kafkaclusternew.jbf0pp.c4.kafka.us-west-2.amazonaws.com:9094, REPLICATION_SECURE=b-1-internal.kafkaclusternew.jbf0pp.c4.kafka.us-west-2.amazonaws.com:9095}]

还尝试用SCHEMA _ REGISTRY _ KAFKASTORE _ BOOTSTRAP _ SERVERS替换SCHEMA _ REGISTRY _ KAFKASTORE _ CONNECTION _ URL

  --net=host \
  --name=schema-registry \
  -e SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS=PLAINTEXT://b-2.kafkaclusternew.jbf0pp.c4.kafka.us-west-2.amazonaws.com:9092,b-3.kafkaclusternew.jbf0pp.c4.kafka.us-west-2.amazonaws.com:9092,b-1.kafkaclusternew.jbf0pp.c4.kafka.us-west-2.amazonaws.com:9092 \
  -e SCHEMA_REGISTRY_HOST_NAME=schema-registry \
  -e SCHEMA_REGISTRY_LISTENERS=http://schema-registry:8081 \
  -e SCHEMA_REGISTRY_DEBUG=true \
  docker.io/confluentinc/cp-schema-registry:latest

仍然失败，错误如下

ERROR Server died unexpectedly:  (io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain)
java.net.SocketException: Unresolved address

请建议对此进行任何修复。

Answer 1

我有同样的问题，不得不使用

SCHEMA_REGISTRY_BOOTSTRAP_SERVERS

代替

SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS

。希望有帮助。