合流模式注册表-AvroProducer-连接错误

Question

我试图使用Confluent_Kafka的AvroProducer类生成Avro格式的消息。Kafka和Schema-Registry在同一个网络中作为3个节点的集群运行。

value_schema = loads("""{"doc": "Messages to be written.",
        "namespace": "schemas.avro",
        "type": "record",
        "name": "kafkagwo",
        "fields": [
            {"name": "timestamp", "type": "string"},
            {"name": "message", "type": "string"}
        ]}""")
key_schema = loads('{"type": "string"}')
p = AvroProducer({'bootstrap.servers': 'broker1,broker2,broker3',
                 'schema.registry.url': 'http://broker1:8081'})

value = {'timestamp': timestamp, 'message': message}
p.produce(topic = 'topic-1', partition=0,
          key=str('key_0'),
          value=value, callback=delivery_report, 
          value_schema = value_schema, key_schema = key_schema)

我得到的是

ConnectionError: HTTPConnectionPool(host='broker1', port=8081): Max retries exceeded with url: /subjects/topic-1-value/versions (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x00000165C1522D88>: Failed to establish a new connection: [WinError 10061] No connection could be made because the target machine actively refused it'))

我没有使用Docker容器。集群由3个独立的VM组成，其中安装和运行Kafka和Registry Schema，所以它也不是独立的。Python代码从具有网络访问和防火墙异常的第四个VM执行。事实上，我可以在没有avro和注册表模式的情况下生成和使用消息，所以我不认为这个问题与网络有关，但我愿意接受各种想法。当我尝试使用带有注册表模式的Avro时，我得到了上面的错误。此外，错误指出注册表模式端口8081，所以问题应该与它有关，但我不知道该进一步寻找什么。

Answer 1

问题是由于schema-registry.properties文件配置造成的。我已经设置了listeners=http://localhost:8081，但是它对应于127.0.0.1，并且不能从另一台机器访问。

我将它更改为listeners=http://0.0.0.0:8081，它就起作用了。