Update test case

Now actually runs the program. Still no assert though.

src/test/kotlin/KafkaEmbedded.kt

@@ -57,7 +57,7 @@ class KafkaEmbedded(port: Int, topic: String) : Closeable {
         val zkUtils = ZkUtils.apply(zkClient, false)
         AdminUtils.createTopic(zkUtils, topic, 1, 1, Properties(), RackAwareMode.`Disabled$`.`MODULE$`)
 
-        TestUtils.waitUntilMetadataIsPropagated(scala.collection.JavaConversions.asScalaBuffer(listOf(server)), topic, 0, 5000)
+        TestUtils.waitUntilMetadataIsPropagated(JavaConversions.asScalaBuffer(listOf(server)), topic, 0, 5000)
     }
 
     override fun close() {

src/test/kotlin/Tests.kt

 /*
- * sftp-readerr
+ * sftp-reader
  * Copyright (C) 2019  Memobase
  *
  * This program is free software: you can redistribute it and/or modify
@@ -19,14 +19,18 @@ package org.memobase
 
 import org.junit.jupiter.api.Assertions.assertEquals
 import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.TestInstance
 import org.junit.jupiter.api.assertAll
 
+@TestInstance(TestInstance.Lifecycle.PER_CLASS)
 class Tests {
 
+    private val kafkaEmbedded = KafkaEmbedded(12301, "test")
+
     @Test
     fun testCase1() {
-        KafkaEmbedded(12301, "test").use {
-
+        kafkaEmbedded.use {
+            App.main(emptyArray())
             assertAll("test case 1",
                 { assertEquals("null", "null") },
                 { assertEquals("null", "null") }

src/test/resources/app.yml

+sftp:
+  host: sb-uingest1.swissbib.ch
+  port: "22"
+  user: mb_sftp
+  password: ${SFTP_PASSWORD:?env}
+  fingerprint: ${HOST_KEY_VERIFIER:?env}
+app:
+  directory: ./test_institution_1/test_record_set_1/
+kafka:
+  producer:
+    bootstrap.servers: localhost:9092
+    client.id: ${CLIENT_ID:?env}
+  topic:
+    out: ${CLIENT_ID:?env}
\ No newline at end of file