Kafka Connect JdbcSourceConnector ExtractField 在字符串周围留下双引号
Kafka Connect JdbcSourceConnector ExtractField leaves double quotes around string
我正在使用 Kafka Connect JdbcSourceConnector 将 DB table 行流式传输到主题中。在 Connect 配置中，我有这些行以便从 table 的 value 列填充 Kafka 消息体：
"transforms": "extract",
"transforms.extract.type": "org.apache.kafka.connect.transforms.ExtractField$Value",
"transforms.extract.field": "value",
基本可以，但是邮件正文在字符串周围多了一个双引号字符，这完全出乎我的意料。例如，如果 table 行在列中有 "value1"（不包括引号），则该行的 Kafka 消息正文为 "\"value1\""（不包括外部引号）。
这是 ExtractField 的预期行为吗？有解决方法吗？我的 KafkaConnect 版本是 2.2.2，如果重要的话，代理版本是 2.5.0。
我通过像这样指定 value.converter 解决了这个问题：
"value.converter": "org.apache.kafka.connect.storage.StringConverter",
使用此配置，我再也看不到额外的双引号字符了。
我正在使用 Kafka Connect JdbcSourceConnector 将 DB table 行流式传输到主题中。在 Connect 配置中，我有这些行以便从 table 的 value 列填充 Kafka 消息体：
"transforms": "extract",
"transforms.extract.type": "org.apache.kafka.connect.transforms.ExtractField$Value",
"transforms.extract.field": "value",
基本可以，但是邮件正文在字符串周围多了一个双引号字符，这完全出乎我的意料。例如，如果 table 行在列中有 "value1"（不包括引号），则该行的 Kafka 消息正文为 "\"value1\""（不包括外部引号）。
这是 ExtractField 的预期行为吗？有解决方法吗？我的 KafkaConnect 版本是 2.2.2，如果重要的话，代理版本是 2.5.0。
我通过像这样指定 value.converter 解决了这个问题：
"value.converter": "org.apache.kafka.connect.storage.StringConverter",
使用此配置，我再也看不到额外的双引号字符了。