diff --git a/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcChangeEventSink.java b/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcChangeEventSink.java index 7f3be2883..acc4ae179 100644 --- a/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcChangeEventSink.java +++ b/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcChangeEventSink.java @@ -9,7 +9,7 @@ import java.sql.SQLException; import java.util.Collection; -import java.util.HashMap; +import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.Optional; @@ -65,8 +65,8 @@ public JdbcChangeEventSink(JdbcSinkConnectorConfig config, StatelessSession sess @Override public void execute(Collection records) { - final Map updateBufferByTable = new HashMap<>(); - final Map deleteBufferByTable = new HashMap<>(); + final Map updateBufferByTable = new LinkedHashMap<>(); + final Map deleteBufferByTable = new LinkedHashMap<>(); for (SinkRecord record : records) {