覆盖 kafka-connect 连接器中的 schemas.enable

Question

我有一个分布式 Kafka Connect (6.x) 集群，安装了多个连接器。键和值转换器设置为

org.apache.kafka.connect.json.JsonConverter

。对于其中一个连接器（S3 接收器），我需要在没有架构的情况下使用事件，因此 schemas.enable 属性在集群配置中设置为 false：

key.converter.schemas.enable=False

、

value.converter.schemas.enable=False

。对于其他（Debezium MySql 源连接器），我需要在事件中添加架构，因此属性应该为 true。

我知道可以覆盖连接器中的配置，但显然这只适用于

producer.

和

consumer.

配置。我尝试覆盖源连接器中的

producer.key.converter.schemas.enable

，但似乎没有效果。

有没有办法在单个 Kafka Connect 集群中实现这一目标？

Answer 1

您可以在相应的连接器配置中继续使用

key/value.converter.schemas.enable

，不带任何前缀，这将覆盖工作器属性。

转换器不是消费者/生产者客户端的财产

Answer 2

我配置了一个JMS 源连接器，没有模式，但值仍然有内置模式数据，设置enable = ture或false不会改变任何东西：