配置kafkajdbc源连接器

Question

我正在处理一个spring-boot应用程序中的kafka当我使用kafkateplate和avro方案生成消息时生成的消息类似于：

"{"kkk":{"string":"somevalue" ....}

但是当我使用kafka-connect-jdbc源连接器时，我会得到这样的东西：

"{"kkk":"somevalue" ...

我的问题是如何使jdbc连接器产生与kafkaTemple 相同的格式

Answer 1

显示的第一个输出是Avro JSON编码。不能删除string类型，除非将字段设置为所需的不可为null和非并集类型

因此，JDBC源似乎已经推断出该列的模式没有null，并且该列始终是varchar类型。