Проведение простого эксперимента в командной строке после загрузки конфлюентного открытого исходного кода 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. Приветствуются любые идеи о том, какая другая конфигурация может потребоваться для успешного подключения к реестру схемы.
