Fix integration test: generate records

exasol · Nov 13, 2023 · 8ce24d6 · 8ce24d6
1 parent 93bce85
commit 8ce24d6
Showing 1 changed file with 3 additions and 8 deletions.
diff --git a/src/test/java/com/exasol/cloudetl/kafka/ExtensionIT.java b/src/test/java/com/exasol/cloudetl/kafka/ExtensionIT.java
@@ -13,7 +13,8 @@
 import java.util.logging.Logger;
 
 import org.hamcrest.Matcher;
-import org.junit.jupiter.api.*;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
 
 import com.exasol.bucketfs.BucketAccessException;
 import com.exasol.dbbuilder.dialects.Table;
@@ -88,13 +89,6 @@ static void teardown() throws Exception {
         }
     }
 
-    @Test
-    void importWorksAfterInstallation() throws SQLException {
-        setup.client().install();
-        kafkaSetup.produceTestTopicRecords();
-        assertScriptsExist();
-    }
-
     @Override
     protected ExtensionManagerSetup getSetup() {
         return setup;
@@ -114,6 +108,7 @@ protected ExtensionITConfig createConfig() {
 
     @Override
     protected void assertScriptsWork() {
+        kafkaSetup.produceTestTopicRecords();
         final ExasolSchema schema = exasolObjectFactory.createSchema("TESTING_SCHEMA_" + System.currentTimeMillis());
         try {
             final Table targetTable = schema.createTableBuilder("TARGET").column("STATUS", "VARCHAR(10)") //