代码之家  ›  专栏  ›  技术社区  ›  user1493570

Confluent 3.3无法通过Kafka Avro控制台生成器本地连接到架构注册表

  •  0
  • user1493570  · 技术社区  · 8 年前

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

    1 回复  |  直到 8 年前
        1
  •  0
  •   Nicola Ben    8 年前

    schema-registry 港口 8081

    sunproxyadmin .

    confluent status

    推荐文章