Change test clean up of connectors and deleting topics ordering

mongodb · Feb 28, 2020 · 80e209f · 80e209f
1 parent 058c62c
commit 80e209f
Showing 1 changed file with 1 addition and 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
@@ -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