Commit 75235498 authored by Günter Hipler's avatar Günter Hipler
Browse files

changed dependency to scala App and deployment manifest

parent ac95aa2a
Pipeline #23117 passed with stages
in 6 minutes and 52 seconds
...@@ -41,5 +41,5 @@ spec: ...@@ -41,5 +41,5 @@ spec:
- name: TOPIC_OUT - name: TOPIC_OUT
value: edm-es-records value: edm-es-records
- name: TOPIC_PROCESS - name: TOPIC_PROCESS
value: postprocessing-reporting value: import-process-reporting
restartPolicy: Always restartPolicy: Always
...@@ -25,10 +25,10 @@ import org.apache.kafka.streams.KafkaStreams ...@@ -25,10 +25,10 @@ import org.apache.kafka.streams.KafkaStreams
import org.apache.logging.log4j.scala.Logging import org.apache.logging.log4j.scala.Logging
import org.memobase.settings.SettingsLoader import org.memobase.settings.SettingsLoader
import scala.collection.JavaConverters._ import scala.jdk.CollectionConverters._
import scala.util.{Failure, Success, Try} import scala.util.{Failure, Success, Try}
object App extends scala.App with Logging { object App extends Logging {
val topology = new KafkaTopology val topology = new KafkaTopology
private val settings = new SettingsLoader( private val settings = new SettingsLoader(
...@@ -64,4 +64,9 @@ object App extends scala.App with Logging { ...@@ -64,4 +64,9 @@ object App extends scala.App with Logging {
sys.ShutdownHookThread { sys.ShutdownHookThread {
streams.close(Duration.ofMillis(shutdownGracePeriodMs)) streams.close(Duration.ofMillis(shutdownGracePeriodMs))
} }
def main(args: Array[String]): Unit = {
}
} }
Supports Markdown
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