From f2e9b1d47ca18aee4694b672336655df0b516491 Mon Sep 17 00:00:00 2001 From: Animesh Kumar Date: Tue, 10 Oct 2023 23:38:26 +0530 Subject: [PATCH] dummy commit --- .../java/io/debezium/connector/mysql/MySqlConnectorTask.java | 2 ++ 1 file changed, 2 insertions(+) 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();