TRACE [MySqlStreamingChangeEventSource.java:logEvent:1033] - Received event: Event{header=EventHeaderV4{timestamp=1722372190000, eventType=XID, serverId=123, headerLength=19, dataLength=12, nextPosition=596337897, flags=0}, data=XidEventData{xid=680417063}}
 TRACE [MySqlStreamingChangeEventSource.java:onEvent:225] - Current milliseconds behind source: 295740 ms
 TRACE [MySqlStreamingChangeEventSource.java:logEvent:1033] - Received event: Event{header=EventHeaderV4{timestamp=1722372234000, eventType=GTID, serverId=123, headerLength=19, dataLength=60, nextPosition=596337976, flags=0}, data=GtidEventData{flags=0, gtid='bdb89c44-8841-11ee-b7e9-0242ac110010:4737977', last_committed='606484', sequence_number='606485', immediate_commit_timestamp='1722372234191164', original_commit_timestamp='1722372234191164', transaction_length='743', immediate_server_version='80018', original_server_version='80018'}}
 TRACE [MySqlStreamingChangeEventSource.java:onEvent:225] - Current milliseconds behind source: 295740 ms
 TRACE [MySqlStreamingChangeEventSource.java:logEvent:1033] - Received event: Event{header=EventHeaderV4{timestamp=1722372234000, eventType=QUERY, serverId=123, headerLength=19, dataLength=60, nextPosition=596338055, flags=8}, data=QueryEventData{threadId=5390508, executionTime=0, errorCode=0, database='', sql='BEGIN'}}
 TRACE [MySqlStreamingChangeEventSource.java:ignoreEvent:250] - Ignoring event due to missing handler: Event{header=EventHeaderV4{timestamp=1722372234000, eventType=ROWS_QUERY, serverId=123, headerLength=19, dataLength=350, nextPosition=596338424, flags=128}, data=RowsQueryEventData{query='/* ApplicationName=DBeaver 22.3.2 - Main */ INSERT INTO fdi_test.table_all_numeric_datetime (int_col,big_int_col,tiny_int_col,medium_int_col,float_col,double_col,small_int_col,decimal_col,datetime_col,timestamp_col,year_col,date_col,time_col)
','2024-10-10 10:00:00',2024,'2024-10-10','10:00:00')'}}
 TRACE [MySqlStreamingChangeEventSource.java:onEvent:225] - Current milliseconds behind source: 295741 ms
 TRACE [MySqlStreamingChangeEventSource.java:logEvent:1033] - Received event: Event{header=EventHeaderV4{timestamp=1722372234000, eventType=ROWS_QUERY, serverId=123, headerLength=19, dataLength=350, nextPosition=596338424, flags=128}, data=RowsQueryEventData{query='/* ApplicationName=DBeaver 22.3.2 - Main */ INSERT INTO fdi_test.table_all_numeric_datetime (int_col,big_int_col,tiny_int_col,medium_int_col,float_col,double_col,small_int_col,decimal_col,datetime_col,timestamp_col,year_col,date_col,time_col)
	VALUES (2,1,2,2,2.0,2.0,2,2,'2024-10-10 10:00:00','2024-10-10 10:00:00',2024,'2024-10-10','10:00:00')'}}
 DEBUG [ChangeEventQueue.java:poll:277] - checking for more records...
 DEBUG [ChangeEventQueue.java:poll:258] - polling records...
 DEBUG [ChangeEventQueue.java:poll:269] - no records available or batch size not reached yet, sleeping a bit...
 DEBUG [MySqlStreamingChangeEventSource.java:onCommunicationFailure:1128] - A communication failure event arrived
com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1722372234000, eventType=TABLE_MAP, serverId=123, headerLength=19, dataLength=77, nextPosition=596338520, flags=0}
	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:343)
	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeTableMapEventData(EventDeserializer.java:315)
	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:239)
	at io.debezium.connector.mysql.strategy.AbstractBinaryLogClientConfigurator$1.nextEvent(AbstractBinaryLogClientConfigurator.java:110)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1068)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: java.io.EOFException: Failed to read remaining 1 of 2 bytes from position 3. Block length: 0. Initial block length: 1.
	at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.fill(ByteArrayInputStream.java:115)
	at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.read(ByteArrayInputStream.java:105)
	at com.github.shyiko.mysql.binlog.event.deserialization.TableMapEventMetadataDeserializer.readBooleanList(TableMapEventMetadataDeserializer.java:144)
	at com.github.shyiko.mysql.binlog.event.deserialization.TableMapEventMetadataDeserializer.deserialize(TableMapEventMetadataDeserializer.java:90)
	at com.github.shyiko.mysql.binlog.event.deserialization.TableMapEventDataDeserializer.deserialize(TableMapEventDataDeserializer.java:49)
	at com.github.shyiko.mysql.binlog.event.deserialization.TableMapEventDataDeserializer.deserialize(TableMapEventDataDeserializer.java:29)
	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:337)
	... 7 common frames omitted
 ERROR [MySqlStreamingChangeEventSource.java:logStreamingSourceState:1047] - Error during binlog processing. Last offset stored = {file=mysql-bin.000050, pos=596337976, gtids=bdb89c44-8841-11ee-b7e9-0242ac110010:1-4737976, server_id=123, event=2}, binlog reader near position = mysql-bin.000050/596338424
 INFO  [BinaryLogClient.java:run:878] - threadExecutor is shut down, terminating keepalive thread
 DEBUG [ChangeEventQueue.java:poll:277] - checking for more records...
 DEBUG [ChangeEventQueue.java:poll:258] - polling records...
 DEBUG [ChangeEventQueue.java:poll:269] - no records available or batch size not reached yet, sleeping a bit...
 ERROR io.debezium.pipeline.ErrorHandler[ErrorHandler.java:setProducerThrowable:52] - Producer failure
io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4{timestamp=1722372234000, eventType=TABLE_MAP, serverId=123, headerLength=19, dataLength=77, nextPosition=596338520, flags=0}
	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.wrap(MySqlStreamingChangeEventSource.java:1092)
	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource$ReaderThreadLifecycleListener.onCommunicationFailure(MySqlStreamingChangeEventSource.java:1137)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1096)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1722372234000, eventType=TABLE_MAP, serverId=123, headerLength=19, dataLength=77, nextPosition=596338520, flags=0}
	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:343)
	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeTableMapEventData(EventDeserializer.java:315)
	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:239)
	at io.debezium.connector.mysql.strategy.AbstractBinaryLogClientConfigurator$1.nextEvent(AbstractBinaryLogClientConfigurator.java:110)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1068)
	... 3 common frames omitted
Caused by: java.io.EOFException: Failed to read remaining 1 of 2 bytes from position 3. Block length: 0. Initial block length: 1.
	at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.fill(ByteArrayInputStream.java:115)
	at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.read(ByteArrayInputStream.java:105)
	at com.github.shyiko.mysql.binlog.event.deserialization.TableMapEventMetadataDeserializer.readBooleanList(TableMapEventMetadataDeserializer.java:144)
	at com.github.shyiko.mysql.binlog.event.deserialization.TableMapEventMetadataDeserializer.deserialize(TableMapEventMetadataDeserializer.java:90)
	at com.github.shyiko.mysql.binlog.event.deserialization.TableMapEventDataDeserializer.deserialize(TableMapEventDataDeserializer.java:49)
	at com.github.shyiko.mysql.binlog.event.deserialization.TableMapEventDataDeserializer.deserialize(TableMapEventDataDeserializer.java:29)
	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:337)
	... 7 common frames omitted