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) {