We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 058c62c commit 80e209fCopy full SHA for 80e209f
src/integrationTest/java/com/mongodb/kafka/connect/embedded/EmbeddedKafka.java
@@ -238,9 +238,9 @@ public void beforeAll(final ExtensionContext context) throws Exception {
238
239
@Override
240
public void afterEach(final ExtensionContext context) throws InterruptedException {
241
- deleteTopicsAndWait(Duration.ofMinutes(4));
242
deleteSinkConnector();
243
deleteSourceConnector();
+ deleteTopicsAndWait(Duration.ofMinutes(4));
244
}
245
246
0 commit comments