diff --git a/src/test/java/com/exasol/cloudetl/kafka/ExtensionIT.java b/src/test/java/com/exasol/cloudetl/kafka/ExtensionIT.java index 16a54c8..6820a5a 100644 --- a/src/test/java/com/exasol/cloudetl/kafka/ExtensionIT.java +++ b/src/test/java/com/exasol/cloudetl/kafka/ExtensionIT.java @@ -250,8 +250,6 @@ private void verifyImportWorks() { .column("KAFKA_PARTITION", "DECIMAL(18, 0)")// .column("KAFKA_OFFSET", "DECIMAL(36, 0)")// .build(); - // CREATE CONNECTION (optional, see - // https://github.com/exasol/kafka-connector-extension/blob/main/doc/user_guide/user_guide.md#importing-records) executeKafkaImport(targetTable, kafkaSetup);