From 80e209f49d8760517d939b5d0ef1d443dae4a18b Mon Sep 17 00:00:00 2001
From: Ross Lawley <ross.lawley@gmail.com>
Date: Fri, 28 Feb 2020 16:39:21 +0000
Subject: [PATCH] Change test clean up of connectors and deleting topics
 ordering

---
 .../java/com/mongodb/kafka/connect/embedded/EmbeddedKafka.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/integrationTest/java/com/mongodb/kafka/connect/embedded/EmbeddedKafka.java b/src/integrationTest/java/com/mongodb/kafka/connect/embedded/EmbeddedKafka.java
index 544781d3..55d8beba 100644
--- a/src/integrationTest/java/com/mongodb/kafka/connect/embedded/EmbeddedKafka.java
+++ b/src/integrationTest/java/com/mongodb/kafka/connect/embedded/EmbeddedKafka.java
@@ -238,9 +238,9 @@ public void beforeAll(final ExtensionContext context) throws Exception {
 
     @Override
     public void afterEach(final ExtensionContext context) throws InterruptedException {
-        deleteTopicsAndWait(Duration.ofMinutes(4));
         deleteSinkConnector();
         deleteSourceConnector();
+        deleteTopicsAndWait(Duration.ofMinutes(4));
     }
 
     @Override