From 4b5cf5e56c10e5b896291fba1e8404d5789b038f Mon Sep 17 00:00:00 2001 From: Vojtech Juranek Date: Fri, 30 Aug 2024 10:56:26 +0200 Subject: [PATCH] DBZ-8187 Don't close transformations in EmbeddedEngine `EmbeddedEngine` can be stopped and started again. Closing the transfomation chain may cause the issue when engine is started again and already closed transformations are applied to stream of data. Restore original behavior of `EmbeddedEngine` and don't close the transformation chain in this engine. --- .../main/java/io/debezium/embedded/EmbeddedEngine.java | 9 --------- 1 file changed, 9 deletions(-) diff --git a/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java b/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java index f682a5ef3..6bb85c0a4 100644 --- a/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java +++ b/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java @@ -483,15 +483,6 @@ public void run() { finally { // Close the offset storage and finally the connector ... stopOffsetStoreAndConnector(connector, connectorClassName, offsetStore, connectorCallback); - // Close the transformation chain. - if (transformations != null) { - try { - transformations.close(); - } - catch (IOException e) { - fail("Failed to close transformations: ", e); - } - } } } catch (EmbeddedEngineRuntimeException e) {