pcvolkmer/onco-analytics-monitor
1
0
Fork 0
mirror of https://github.com/pcvolkmer/onco-analytics-monitor.git synced 2025-07-02 16:52:54 +00:00
Code Issues Activity

chore: replace topic pattern

Browse Source
This commit is contained in:
Paul-Christian Volkmer
2024-08-05 21:26:29 +02:00
parent 8a55e9fae5
commit d6c651468a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/topiclisteners/ObdsXmlTopicMonitor.kt
View File

@ -26,7 +26,7 @@ class ObdsXmlTopicMonitor(
statisticsEventProducer: StatisticsSink, statisticsEventProducer: StatisticsSink,
) : TopicMonitor(statisticsEventProducer) { ) : TopicMonitor(statisticsEventProducer) {
@KafkaListener(topicPattern = "input.*") @KafkaListener(topicPattern = "onkostar.MELDUNG_EXPORT.*")
override fun handleTopicRecord( override fun handleTopicRecord(
@Header(KafkaHeaders.RECEIVED_TOPIC) topic: String, @Header(KafkaHeaders.RECEIVED_TOPIC) topic: String,
@Header(KafkaHeaders.RECEIVED_TIMESTAMP) timestamp: Long, @Header(KafkaHeaders.RECEIVED_TIMESTAMP) timestamp: Long,