lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

update kafka-resetter for the 3 applications

Browse source
This commit is contained in:
Adam 2022-02-09 23:02:16 +01:00
parent 66fa1fb53a
commit e263275479
1 changed files with 20 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

25
modules/events-server/build.gradle.kts
View file

@ -66,16 +66,31 @@ tasks.withType<KotlinCompile> {
)
}
val kafkatorioEventsServerKafkaForceReset by tasks.registering(Exec::class) {
val kafkatorioEventsServerKafkaForceReset by tasks.registering {
group = project.name
val cmd = """
/kafka/bin/kafka-streams-application-reset.sh --application-id kafkatorio-events-processor --input-topics factorio-server-log --force
fun reset(applicationId: String) = """
/kafka/bin/kafka-streams-application-reset.sh --application-id $applicationId --force
""".trimIndent()
logging.captureStandardOutput(LogLevel.LIFECYCLE)
doLast {
commandLine = parseSpaceSeparatedArgs(""" docker exec -d kafka $cmd """)
exec {
val cmd = reset("kafkatorio-events-processor.saveTiles")
logging.captureStandardOutput(LogLevel.LIFECYCLE)
commandLine = parseSpaceSeparatedArgs(""" docker exec -d kafka $cmd """)
}
exec {
val cmd = reset("kafkatorio-events-processor.splitPackets")
logging.captureStandardOutput(LogLevel.LIFECYCLE)
commandLine = parseSpaceSeparatedArgs(""" docker exec -d kafka $cmd --input-topics factorio-server-log """)
}
exec {
val cmd = reset("kafkatorio-events-processor.playerUpdates")
logging.captureStandardOutput(LogLevel.LIFECYCLE)
commandLine = parseSpaceSeparatedArgs(""" docker exec -d kafka $cmd """)
}
}
}
//tasks.run.configure {