diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlConnectorTask.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlConnectorTask.java index 5474d787527..e8629b3f2ce 100644 --- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlConnectorTask.java +++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlConnectorTask.java @@ -101,6 +101,8 @@ public ChangeEventSourceCoordinator start(Co throw new DebeziumException(e); } + // some random comment + MySqlPartition partition = previousOffsets.getTheOnlyPartition(); MySqlOffsetContext previousOffset = previousOffsets.getTheOnlyOffset();