在 kafka-connect 连接器中覆盖 schemas.enable
Override schemas.enable in kafka-connect connector
我有一个安装了多个连接器的分布式 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 源连接器）我需要在事件中添加模式，因此属性应该是真实的。
我知道 it's possible to override configs in the connectors，但显然这只适用于 producer. 和 consumer. 配置。我尝试在源连接器中覆盖 producer.key.converter.schemas.enable，但它似乎没有效果。
有没有办法在单个 Kafka Connect 集群中实现这一点？
您将在相应的连接器配置中继续使用 key/value.converter.schemas.enable，不带任何前缀，这将覆盖工作程序属性。
转换器不是 consumer/producer 客户的属性
我有一个安装了多个连接器的分布式 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 源连接器）我需要在事件中添加模式，因此属性应该是真实的。
我知道 it's possible to override configs in the connectors，但显然这只适用于 producer. 和 consumer. 配置。我尝试在源连接器中覆盖 producer.key.converter.schemas.enable，但它似乎没有效果。
有没有办法在单个 Kafka Connect 集群中实现这一点？
您将在相应的连接器配置中继续使用 key/value.converter.schemas.enable，不带任何前缀，这将覆盖工作程序属性。
转换器不是 consumer/producer 客户的属性