From 4d27337ab82a47c48217688ca2bf69394a4d1918 Mon Sep 17 00:00:00 2001
From: Vojtech Juranek <vjuranek@redhat.com>
Date: Thu, 8 Aug 2024 13:56:26 +0200
Subject: [PATCH] DBZ-8128 Don't stop engine twice

---
 .../connector/binlog/BinlogConvertingFailureIT.java         | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogConvertingFailureIT.java b/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogConvertingFailureIT.java
index 68f8be5a8..ade7aa59e 100644
--- a/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogConvertingFailureIT.java
+++ b/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogConvertingFailureIT.java
@@ -239,8 +239,6 @@ public void shouldFailedConvertedValueIsNullWithSkipMode() throws Exception {
 
         SourceRecord tombstoneEvent = recordsForTopic.get(3);
         assertTombstone(tombstoneEvent);
-
-        stopConnector();
     }
 
     @Test
@@ -268,7 +266,7 @@ public void shouldFailConversionNotNullTimeTypeWithConnectModeWhenWarnMode() thr
         }
 
         waitForConnectorShutdown(getConnectorName(), DATABASE.getServerName());
-        stopConnector();
+        waitForEngineShutdown();
 
         final Throwable e = exception.get();
         if (e == null) {
@@ -301,7 +299,7 @@ public void shouldFailConversionTimeTypeWithConnectModeWhenFailMode() throws Exc
         }
 
         waitForConnectorShutdown(getConnectorName(), DATABASE.getServerName());
-        stopConnector();
+        waitForEngineShutdown();
 
         final Throwable e = exception.get();
         if (e == null) {