在kafka-connect连接器中启用

kgsdhlau 于 12个月前发布在 Apache

关注(0)|答案(2)|浏览(126)

我有一个分布式的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.key.converter.schemas.enable，但显然这只对producer.和consumer.producer.key.converter.schemas.enable有效。我尝试在源连接器中覆盖producer.key.converter.schemas.enable，但似乎没有效果。
有没有一种方法可以在单个Kafka Connect集群中实现这一点？

apache-kafka

来源：https://stackoverflow.com/questions/65798992/override-schemas-enable-in-kafka-connect-connector