下载Confluent开源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 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
.对于成功连接到模式注册表可能需要什么其他配置的任何想法都是值得赞赏的。