Commit 379962dc authored by Matthias's avatar Matthias
Browse files

first steps for new workflow and adding thumbnails

parent 76417b05
Pipeline #15356 passed with stages
in 6 minutes and 12 seconds
......@@ -64,7 +64,7 @@ class KafkaTopology(private val settings: SettingsLoader) {
}
}
private val reportingTopic = "${settings.outputTopic}-${Constant.topicReportingSuffix}"
private val reportingTopic = "${settings.processReportTopic}-${Constant.topicReportingSuffix}"
fun prepare(): StreamsBuilder {
val builder = StreamsBuilder()
......
......@@ -53,9 +53,12 @@ class TestKafkaTopology {
init {
val files = listOf(
Pair("/base/test_record_set_1/media", "MEI_49884.jpg"),
Pair("/base/test_record_set_1/media", "MEI_49885.jpg"),
Pair("/base/test_record_set_1/media", "MEI_49886.jpg")
Pair("/base/test_record_set_1/media", "MEI_49884.jpg"),
Pair("/base/test_record_set_1/media", "MEI_49885.jpg"),
Pair("/base/test_record_set_1/media", "MEI_49886.jpg"),
Pair("/base/test_record_set_1/thumbnails", "MEI_49884_thumbnail.jpg"),
Pair("/base/test_record_set_1/thumbnails", "MEI_49885_thumbnail.jpg"),
Pair("/base/test_record_set_1/thumbnails", "MEI_49886_thumbnail.jpg")
)
for (pair in files) {
......
......@@ -7,6 +7,7 @@ app:
recordSetId: test_record_set_1
sftp:
basePath: /base
hasThumbnails: false
kafka:
streams:
bootstrap.servers: localhost:12345
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment