Confluent JDBC Source Connect v5.2.2 дает "org.apache.kafka.connect.errors.DataException"

Question

Я использую автономный коннектор confluent-jdbc-source v5.2.2 с использованием confluent-schema-registry для извлечения данных таблицы из DB2 v10.5.0.10.Все отлично работает в v5.0.0, но я получаю следующую ошибку с v5.2.2.

ERROR WorkerSourceTask{id=source-ibm-db2-jdbc-project-0} Task threw an uncaught and unre
coverable exception (org.apache.kafka.connect.runtime.WorkerTask)
org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler
        at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.ja
va:178)
        at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.convertTransformedRecord(WorkerSourceTask.java:269)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:293)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:228)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.kafka.connect.errors.DataException: Kafka Connect Date type should not have any time fields set to non-z
ero values.
        at org.apache.kafka.connect.data.Date.fromLogical(Date.java:64)
        at io.confluent.connect.avro.AvroData$6.convert(AvroData.java:275)
        at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:419)
        at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:606)
        at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:365)
        at io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:77)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.lambda$convertTransformedRecord$2(WorkerSourceTask.java:269)
        at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128
)
        at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.ja
va:162)
        ... 11 more
[2019-07-05 12:19:25,217] ERROR WorkerSourceTask{id=source-ibm-db2-jdbc-project-0} Task is being killed and will n
ot recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask)

confluent-jdbc-source-connector.properties

connection.url=jdbc:db2://*****:50000/dbName
connection.user=*****
connection.password=*****

schema.pattern=schemaName
table.whitelist=TableName
poll.interval.ms=5000
validate.non.null=false

mode=timestamp
timestamp.column.name=CREATE_TIMESTAMP,SYN_TIMESTAMP
db.timezone= Asia/Hong_Kong
numeric.mapping=best_fit

topic.prefix=TopicPrefix.

transforms=ExtractKey, SetSchemaMetadata, SetSchemaMetadataKey
transforms.ExtractKey.type=org.apache.kafka.connect.transforms.ValueToKey
transforms.ExtractKey.fields=ID

transforms.SetSchemaMetadataKey.type=org.apache.kafka.connect.transforms.SetSchemaMetadata$Key
transforms.SetSchemaMetadataKey.schema.name=namespace.ClassNameKey
transforms.SetSchemaMetadataKey.schema.version=1

transforms.SetSchemaMetadata.type= org.apache.kafka.connect.transforms.SetSchemaMetadata$Value
transforms.SetSchemaMetadata.schema.name=namespace.ClassNameValue
transforms.SetSchemaMetadata.schema.version=1

connect-standalone.properties

###JsonConverter###
#key.converter=org.apache.kafka.connect.json.JsonConverter
#value.converter=org.apache.kafka.connect.json.JsonConverter

#key.converter.schemas.enable=false
#value.converter.schemas.enable=false

###AvroConverter###
key.converter=io.confluent.connect.avro.AvroConverter
key.converter.schema.registry.url=http://localhost:8084

value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=http://localhost:8084

offset.flush.interval.ms=10000
plugin.path=/Users/confluent-5.2.2/share/java/confluentinc-kafka-connect-jdbc-5.2.2

Я также попытался использовать JsonConverter, закомментировав все связанные поля AvroConverter из connect-standalone.properties, но подобная ошибка все еще сохраняется.

В таблице базы данных IBM DB2 есть следующие столбцы: CREATE_TIMESTAMP (TYPE_NAME = TIMESTAMP, IS_NULLABLE = NO), SYN_TIMESTAMP (TYPE_NAME = TIMESTAMP, IS_NULLABLE = YES), EVENT_DATE (TYPE_NAME = NOLLAB_N = =), DATE, ISATE, DATE, ISATEстолбцы - это CHAR, DECIMALS и VARCHAR, определенные с IS_NULLABLE = NO

Почему это работает для v5.0.0, но не для v5.2.2?Причина, по которой я хочу использовать v5.2.2, заключается в том, что аналогичный коннектор confluent-jdbc-sink, который я определил для IBM DB2 Database, не работает с v5.0.0, но работает с v5.2.2.Я хотел бы использовать последнюю версию как для приемника, так и для источника jdbc.