Confluent 3.3 не может подключиться к системному реестру локально с помощью kafka-avro-console -roduction - PullRequest
Новая
       6

Confluent 3.3 не может подключиться к системному реестру локально с помощью kafka-avro-console -roduction

0 голосов
/ 29 июня 2018

Выполнение простого эксперимента в командной строке после загрузки конфлуентного открытого источника 3.3:

Confluent Start - который запускает все службы без видимых ошибок: 

confluent-3.3.0%   confluent start
Starting zookeeper
zookeeper is [UP]
Starting kafka
kafka is [UP]
Starting schema-registry
schema-registry is [UP]
Starting kafka-rest
kafka-rest is [UP]
Starting connect
connect is [UP]

Отправьте сообщение производителю консоли avro и увидите ошибку соединения с localhost: 8081, порт схемы по умолчанию: 

confluent-3.3.0%   bin/kafka-avro-console-producer --broker-list localhost:9092 --topic test --property value.schema='{"type":"record","name":"myrecord","fields":[{"name":"f1","type":"string"}]}'
{"f1": "value1"}
[2018-06-28 12:22:47,827] ERROR Failed to send HTTP request to endpoint: http://localhost:8081/subjects/test-value/versions (io.confluent.kafka.schemaregistry.client.rest.RestService:156)
java.net.ConnectException: Connection refused

Вышеприведенные сведения взяты из документации по слитной платформе. https://docs.confluent.io/3.3.0/quickstart.html. Любые идеи о том, какие другие конфигурации могут потребоваться для успешного подключения к реестру схемы, приветствуются.

1 Ответ

0 голосов
/ 29 июня 2018

Публикация того, что сработало для меня, поскольку я видел много других вопросов без ответа с похожей проблемой - перезапуск моего ноутбука, к сожалению, сделал свое дело.

На Mac вы можете использовать Network Utility -> Port Scan, чтобы проверить, работает ли что-либо на стандартном schema-registry порту 8081.

Появляется как sunproxyadmin.

До перезапуска ничего не показывалось для этого порта, хотя confluent status время от времени сообщал о реестре схемы как 'UP'.

...