0

我正在使用融合卡夫卡。

我的代码是

producer = SimpleAvroProducer(producer_id="producer_1",
                              topic_name="events_topic",
                              broker_host= brkr_host,
                              broker_port= brkr_port,
                              schema_registry_host= schema_registry_host,
                              schema_registry_port= schema_registry_port,
                              key_schema_path=None,
                              value_schema_path=DIR_PATH + "/event_schema.avsc",
                              configurations={"schema.compatibility.level": "none",
                                              })

运行这个时，我得到

E       cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "schema.compatibility.level""}

即使使用旧avro.compatibility.level参数也会引发相同的错误

E       cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "avro.compatibility.level""}

它适用于其他参数，例如 "acks": "all","debug": "msg"但不适用于兼容性级别。

请帮我解决这个问题。旧模式有很多变化，既不向前也不向后兼容。我需要将其设置为 None 。请帮忙。！

4

1 回答 1

1

客户端中未设置兼容级别。它在注册表服务器端设置

于 2021-09-07T11:14:46.630 回答