集群中的数据已使用AvroConverter加载,模式详细信息还包含源、op、ts_ms等字段。这里的问题是,当我试图从集群读取数据时,它试图将这些模式字段作为附加列添加到我的目标表中,并引发一个错误:
INFO Unable to find fields [SinkRecordField{schema=Schema{Tab1.Value:STRUCT}, name='after', isPrimaryKey=false}, SinkRecordField{schema=Schema{io.debezium</