diff --git a/debezium-connector-ibmi/src/main/java/io/debezium/connector/db2as400/As400ConnectorTask.java b/debezium-connector-ibmi/src/main/java/io/debezium/connector/db2as400/As400ConnectorTask.java index a613719..4f2cc73 100644 --- a/debezium-connector-ibmi/src/main/java/io/debezium/connector/db2as400/As400ConnectorTask.java +++ b/debezium-connector-ibmi/src/main/java/io/debezium/connector/db2as400/As400ConnectorTask.java @@ -96,7 +96,7 @@ protected ChangeEventSourceCoordinator start if (previousOffset == null) { LOGGER.info("previous offsets not found creating from config"); previousOffset = new As400OffsetContext(connectorConfig); - previousOffsetPartition = Offsets.of(new As400Partition(connectorConfig.getHostname()), + previousOffsetPartition = Offsets.of(new As400Partition(connectorConfig.getLogicalName()), previousOffset); }