Подключение схемы-реестра Docker-контейнера к AWS MSK

Question

Я не могу подключить реестр схемы к MSK. Я запускаю Docker в отдельном экземпляре, и у меня включены подключения к службам MSK.

Испытанное изображение докера из слияния docker.io/confluentinc/cp-schema-registry:latest.

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_CONNECTION_URL на SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS

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

, Надеюсь, это поможет.