Commit 452e3426 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Update dependecies

parent 331162cf
......@@ -19,44 +19,37 @@ sourceCompatibility = 1.8
targetCompatibility = 1.8
repositories {
jcenter()
mavenCentral()
maven {
url "https://dl.bintray.com/memoriav/memobase"
url "https://gitlab.switch.ch/api/v4/projects/1324/packages/maven"
}
}
ext {
kafkaV = '2.3.1'
kafkaV = '2.7.0'
log4jV = '2.11.2'
}
dependencies {
implementation 'ch.memobase:memobase-kafka-utils:0.2.3'
implementation 'org.memobase:memobase-service-utilities:2.0.15'
implementation 'ch.memobase:mapper-service-configuration:1.0.9'
// Logging Framework
implementation "org.apache.logging.log4j:log4j-api:${log4jV}"
implementation 'ch.memobase:memobase-kafka-utils:0.3.1'
implementation 'ch.memobase:mapper-service-configuration:1.0.12'
implementation 'org.memobase:memobase-service-utilities:3.0.1'
implementation "org.apache.logging.log4j:log4j-core:${log4jV}"
// Kafka Imports
//implementation group: 'org.apache.kafka', name: 'kafka-clients', version: kafkaV
implementation "org.apache.kafka:kafka-streams:${kafkaV}"
// YAML Parser
implementation 'org.snakeyaml:snakeyaml-engine:2.1'
implementation 'org.apache.jena:apache-jena:3.14.0'
// JSON Parser
implementation 'com.beust:klaxon:5.2'
implementation 'com.beust:klaxon:5.5'
implementation 'org.jetbrains.kotlin:kotlin-stdlib-jdk8'
implementation "org.jetbrains.kotlin:kotlin-script-runtime:1.3.71"
implementation "org.jetbrains.kotlin:kotlin-reflect:1.3.71"
testCompile("org.junit.jupiter:junit-jupiter:5.4.2")
testImplementation("org.junit.jupiter:junit-jupiter:5.4.2")
testImplementation 'org.assertj:assertj-core:3.15.0'
// https://mvnrepository.com/artifact/org.apache.kafka/kafka-streams-test-utils
testCompile group: 'org.apache.kafka', name: 'kafka-streams-test-utils', version: kafkaV
testImplementation group: 'org.apache.kafka', name: 'kafka-streams-test-utils', version: kafkaV
}
compileKotlin {
......
......@@ -38,7 +38,7 @@ class Service(file: String = "app.yml") {
val stream = KafkaStreams(KafkaTopology(settings).prepare().build(), settings.kafkaStreamsSettings)
stream.use {
it.start()
while (stream.state().isRunning) {
while (stream.state().isRunningOrRebalancing) {
log.info("Service is running.")
Thread.sleep(10_000L)
}
......
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