Unverified Commit 91f2ee72 authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files

update kafka version & topic names

parent 44b9286a
......@@ -40,17 +40,17 @@ targetCompatibility = 1.8
repositories {
jcenter()
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 'org.memobase:memobase-service-utilities:2.0.14'
implementation 'org.memobase:memobase-service-utilities:3.0.0'
// Logging Framework
implementation "org.apache.logging.log4j:log4j-api:${log4jV}"
......
......@@ -10,8 +10,8 @@ tag: "latest"
deploymentName: pp-import-process-bridge
kafkaConfigs: prod-kafka-bootstrap-servers
outputTopic: fedora-output-json
inputTopic: import-process-ingest
reportingTopic: import-process-reporting
recordsTransactionsTopic: import-process-transactions-records
recordSetsTransactionsTopic: import-process-transactions-record-sets
institutionsTransactionsTopic: import-process-transactions-institutions
\ No newline at end of file
inputTopic: mb-di-ingest-prod
reportingTopic: mb-di-reporting-prod
recordsTransactionsTopic: mb-di-transactions-records-prod
recordSetsTransactionsTopic: mb-di-transactions-record-sets-prod
institutionsTransactionsTopic: mb-di-transactions-institutions-prod
\ No newline at end of file
......@@ -18,9 +18,9 @@
package org.memobase
import ch.memobase.settings.SettingsLoader
import kotlin.system.exitProcess
import org.apache.kafka.streams.KafkaStreams
import org.apache.logging.log4j.LogManager
import kotlin.system.exitProcess
class Service(file: String = "app.yml") {
private val log = LogManager.getLogger("ImportProcessBridgeService")
......@@ -41,7 +41,7 @@ class Service(file: String = "app.yml") {
fun run() {
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