flink cdc对接多主的mysql集群会报错如下,请问要怎么配置。感谢各位大佬。


2021-06-16 16:26:46 ERROR [blc-centos7-01:3306] 
io.debezium.connector.mysql.BinlogReader:864 - Encountered change event 
'Event{header=EventHeaderV4{timestamp=1623829662000, eventType=TABLE_MAP, 
serverId=2, headerLength=19, dataLength=97, nextPosition=51557, flags=0}, 
data=TableMapEventData{tableId=519, database='test3', table='order_main', 
columnTypes=8, 15, 15, 15, 3, 15, 15, 8, 15, 18, 3, 3, 3, 3, 15, 15, 3, 8, 18, 
8, 18, 3, 15, 15, 3, 15, columnMetadata=0, 200, 80, 400, 0, 80, 256, 0, 400, 0, 
0, 0, 0, 0, 400, 4000, 0, 0, 0, 0, 0, 0, 40, 1020, 0, 400, 
columnNullability={1, 2, 3, 5, 6, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 
20, 21, 22, 23, 24, 25}, eventMetadata=TableMapEventMetadata{signedness={}, 
defaultCharset=255, charsetCollations=null, columnCharsets=null, 
columnNames=null, setStrValues=null, enumStrValues=null, geometryTypes=null, 
simplePrimaryKeys=null, primaryKeysWithPrefix=null, 
enumAndSetDefaultCharset=null, enumAndSetColumnCharsets=null}}}' at offset 
{ts_sec=1623829662, file=binlog.000001, pos=51370, 
gtids=45ac41f5-69b4-11eb-ad27-000c298c2812:1-103,d93dfbb8-66bb-11eb-9a1e-000c29fb00ac:1-8,
 server_id=2, event=1} for table test3.order_main whose schema isn't known to 
this connector. One possible cause is an incomplete database history topic. 
Take a new snapshot in this case.

Use the mysqlbinlog tool to view the problematic event: mysqlbinlog 
--start-position=51441 --stop-position=51557 --verbose binlog.000001

 2021-06-16 16:26:46 ERROR [blc-centos7-01:3306] 
io.debezium.connector.mysql.BinlogReader:1178 - Error during binlog processing. 
Last offset stored = null, binlog reader near position = binlog.000001/51441

 2021-06-16 16:26:46 ERROR [blc-centos7-01:3306] 
io.debezium.connector.mysql.BinlogReader:219 - Failed due to error: Error 
processing binlog event

 org.apache.kafka.connect.errors.ConnectException: Encountered change event for 
table test3.order_main whose schema isn't known to this connector

at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241) 
~[flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218) 
~[flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:607) 
~[flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

at 
com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1104)
 [flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

at 
com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:955)
 [flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

at 
com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:595)
 [flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

at 
com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:839) 
[flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

at java.lang.Thread.run(Thread.java:748) [?:1.8.0_271]

Caused by: org.apache.kafka.connect.errors.ConnectException: Encountered change 
event for table test3.order_main whose schema isn't known to this connector

at 
io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:875)
 ~[flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

at 
io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:849)
 ~[flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:590) 
~[flink-connector-mysql-cdc-1.3.0.jar:1.3.0]

... 5 more
















--

kingdomad

回复