Kafka - реестр схем недоступен

Я загрузил Confluent Platform (на локальном ноутбуке MacOS) и выполнил инструкции по запуску kafka: https://docs.confluent.io/current/schema-registry/docs/intro.html

~/kafka/confluent-4.0.0/bin » confluent start schema-registry                                                                                                                                                                                               dnk306@9801a7a5b33d
Starting zookeeper
zookeeper is [UP]
Starting kafka
kafka is [UP]
Starting schema-registry
schema-registry is [UP]

Схема-реестр при просмотре выше кажется, что она работает. Как проверить, что действительно работает?

curl http://localhost:8081
curl: (7) Failed to connect to localhost port 8081: Connection refused

apache-kafka confluent-schema-registry
person Joe    schedule 09.04.2018    source источник
comment
проверьте свой schema-registry.properties, чтобы узнать, на каком порту он работает   -  person Liju John    schedule 09.04.2018
comment
listeners=http://0.0.0.0:8081 находится в файле schema-registry.properties .. Что делать дальше?   -  person Joe    schedule 09.04.2018

Ответы (2)


arrow_upward
2
arrow_downward

Сначала вам нужно проверить, работает ли реестр схемы. Для этого вам нужно запустить

confluent status schema-registry

Затем вы можете проверить журналы службы и увидеть, были ли зарегистрированы какие-либо ERROR (чтобы получить последние 100 строк файла журнала и далее):

confluent log schema-registry -n 100 -f

Если вы убедитесь, что экземпляр запущен и работает, и об ошибках не сообщается, попробуйте получить все темы.

curl -X GET http://localhost:8081/subjects
person Giorgos Myrianthous    schedule 18.03.2019

arrow_upward
1
arrow_downward

Вот что-то, что, вероятно, вы можете попробовать проверить, правильно ли работает ваш реестр схемы:

1) Сначала вы хотите, чтобы ваш java-процесс схемы-реестра работал или нет. вы можете использовать простую команду ps, чтобы найти его. например. ps ax | grep java | grep schema-registry

2) После того, как вы убедитесь, что ваш процесс реестра схемы работает правильно, вы можете увидеть файл свойств, который он использует в выходных данных, вы можете найти там слушателей, kafkstore.connection.url и kafkaStore.topic.

3) Теперь вы знаете, какую именно конфигурацию использует эта служба реестра схем, вы можете проверить, существует ли эта тема в кластере kafka, или использовать curl для проверки возможности подключения.

4) Если что-то не так, вы можете проверить параметры -Dschema-registry.log.dir и -Dlog4j.configuration и, изменив уровень OUTPUT на DEBUG в конфигурационном файле log4j, который он использует, вы можете получить гораздо больше полезной информации в выводе вашего журнала.

person Yang Xu    schedule 18.03.2019