KafkaJDBCSinkConnector创建的数据类型与原始数据类型不匹配

可以在连接器配置文件中指定Schema Registry的地址，以便在将数据写入目标数据库之前，通过Schema Registry来确保数据类型的匹配性。例如：

name=jdbc-sink
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
tasks.max=1
topics=test_topic
connection.url=jdbc:postgresql://localhost:5432/testdb
connection.user=testuser
connection.password=testpassword
auto.create=true
table.name.format=test_table
insert.mode=upsert
pk.mode=record_value
pk.fields=id

# 添加以下配置
key.converter=io.confluent.connect.avro.AvroConverter
value.converter=io.confluent.connect.avro.AvroConverter
key.converter.schema.registry.url=http://localhost:8081
value.converter.schema.registry.url=http://localhost:8081

通过指定key.converter.schema.registry.url和value.converter.schema.registry.url来确保读取的数据类型与写入的数据类型一致。这需要在使用Schema Registry的情况下才能生效。