Kafka Connect JdbcSourceConnector ExtractField在字符串周围留下双引号



我正在使用Kafka Connect JdbcSourceConnector将DB表行流式传输到主题中。在Connect配置中,我有以下几行,以便从表的value列填充Kafka消息体:

"transforms": "extract",
"transforms.extract.type": "org.apache.kafka.connect.transforms.ExtractField$Value",
"transforms.extract.field": "value",

它基本上可以工作,但消息正文在字符串周围有额外的双引号字符,这是我完全出乎意料的。例如,如果一个表行的列中有"value1"(不包括引号(,则该行的Kafka消息体为""value1""(不包括外引号(。

这是ExtractField的预期行为吗?这方面有什么办法吗?我的KafkaConnect版本是2.2.2,而broker版本是2.5.0。

我通过如下指定value.converter来解决问题:

"value.converter": "org.apache.kafka.connect.storage.StringConverter",

有了这个配置,我再也看不到额外的双引号字符了。

最新更新