From 5ae73a8060efdb0727d8e17326f59d70c5284fc4 Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Fri, 4 Oct 2024 04:47:55 -0400 Subject: [PATCH] DBZ-8298 Use logical name when creating offset partition name --- .../java/io/debezium/connector/db2as400/As400ConnectorTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); }