Merge branch 'master' into release-1.2.0

Author: blootsvoets

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)