Fix Jackson version

Author: blootsvoets

build.gradle

@@ -19,7 +19,7 @@ ext {
     issueUrl = "${githubUrl}/issues"
 
     avroVersion = '1.10.1'
-    jacksonVersion = '2.12.0'
+    jacksonVersion = '2.11.4'
     hadoopVersion = '3.3.0'
     jCommanderVersion = '1.78'
     almworksVersion = '1.1.2'
@@ -48,7 +48,7 @@ configurations {
 
 dependencies {
     api group: 'org.apache.avro', name: 'avro', version: avroVersion
-    implementation group: 'com.fasterxml.jackson.core' , name: 'jackson-databind', version: jacksonVersion
+    api group: 'com.fasterxml.jackson.core' , name: 'jackson-databind', version: jacksonVersion
     implementation group: 'com.fasterxml.jackson.dataformat' , name: 'jackson-dataformat-yaml', version: jacksonVersion
     implementation group: 'com.fasterxml.jackson.dataformat' , name: 'jackson-dataformat-csv', version: jacksonVersion
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin:$jacksonVersion")

src/main/java/org/radarbase/output/source/AzureSourceStorage.kt

@@ -24,7 +24,6 @@ class AzureSourceStorage(
             .asSequence()
             .map { SimpleFileStatus(Paths.get(it.name), it.isPrefix ?: false, it.properties?.lastModified?.toInstant()) }
 
-
     override fun createTopicFile(topic: String, status: SimpleFileStatus): TopicFile {
         var topicFile = super.createTopicFile(topic, status)
 

src/main/java/org/radarbase/output/source/GeneralSourceStorageWalker.kt

@@ -16,8 +16,8 @@ class GeneralSourceStorageWalker(
             }
 
     private fun findTopicPaths(path: Path): Sequence<Path> {
-        val fileStatuses = kafkaStorage.list(path)
-        val avroFile = fileStatuses.find {  !it.isDirectory && it.path.fileName.toString().endsWith(".avro", true) }
+        val fileStatuses = kafkaStorage.list(path).toList()
+        val avroFile = fileStatuses.find { !it.isDirectory && it.path.fileName.toString().endsWith(".avro", true) }
 
         return if (avroFile != null) {
             sequenceOf(avroFile.path.parent.parent)