alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-7567 Fix null event timestamp possible from FORMAT_DESCRIPTION and PREVIOUS_GTIDS events in MySqlStreamingChangeEventSource::setEventTimestamp

Browse Source
This commit is contained in:
Lourens Naude 2024-02-27 00:07:27 +00:00 committed by Jiri Pechanec
parent c3ff0fb197
commit bba11001b3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
View File

@ -227,7 +227,7 @@ protected void onEvent(MySqlOffsetContext offsetContext, Event event) {
}
private void setEventTimestamp(Event event, long eventTs) {
if (connection.isMariaDb() || !isGtidModeEnabled) {
if (eventTimestamp == null || connection.isMariaDb() || !isGtidModeEnabled) {
// Fallback to second resolution event timestamps
eventTimestamp = Instant.ofEpochMilli(eventTs);
}