下载confluent open source 3.3后在命令行上做一个简单的实验:
合流启动-在没有任何可见错误的情况下启动所有服务:
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 console producer发送消息,并查看到的连接错误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条答案
按热度按时间z3yyvxxp1#
发布对我有用的东西,就像我看到许多其他类似问题的未解之谜一样——令人遗憾的是,重启我的笔记本电脑才是成功的秘诀。
在mac上,您可以使用network utility-->port scan来验证是否在默认服务器上运行任何操作
schema-registry
港口8081
.它显示为
sunproxyadmin
.在重新启动之前,该端口没有显示任何内容,即使
confluent status
有时将架构注册表报告为“向上”。