使用JDBC同步连接器获取以下错误。
ERROR WorkerSinkTask{id=12sink-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: Cannot ALTER TABLE "new1501"."test"."patient3" to add missing field SinkRecordField{schema=Sche
我有一个postgres连接到Kafka,使用Kafka,以便将CDC事件放在一个主题上。我们使用扁平化转换作为共享配置的一部分:
flattenKey: "org.apache.kafka.connect.transforms.Flatten$Key"
表中的一个列类型为数组,因此,当试图应用转换时,我会得到一个异常:
Flatten transformation does not support ARRAY for record without schemas (for field after.role_ids).
卡夫卡连接参考:
我知道数组不能被夷为平地,为什么,我的
我尝试使用kafka connect将数据汇聚到postgresql中,但我得到的错误是模式不存在。
有没有可能是包含点的主题的名称造成了问题,因为错误提到模式"logstash“不存在,而这是直到第一个点的字符串?
错误:
org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerS