我正在尝试将mysql与kafka连接起来。我下载了debezium-debezium-connector-mysql这是我的connect-standalone.properties:
# These are defaults./share/confluent-hub-components/debezium-debezium-connector-mysql/lib/mysql-binlog-connector-java-0.19.1:
我正在尝试将数据从Kafka集群加载到Oracle DB中。集群中的数据已使用AvroConverter加载,模式详细信息还包含源、op、ts_ms等字段。schema=Schema{Tab1.Value:STRUCT}, name='after', isPrimaryKey=false}, SinkRecordField{schema=Schema{io.debezium.connector.oracle.SourceError: Cannot ALTER TABLE "Tab1" to add missing fi