From d6c651468a84234d44c95a01c72e00179fff149c Mon Sep 17 00:00:00 2001 From: Paul-Christian Volkmer Date: Mon, 5 Aug 2024 21:26:29 +0200 Subject: [PATCH] chore: replace topic pattern --- .../oncoanalytics/monitor/topiclisteners/ObdsXmlTopicMonitor.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/topiclisteners/ObdsXmlTopicMonitor.kt b/src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/topiclisteners/ObdsXmlTopicMonitor.kt index c4e4a4e..c986809 100644 --- a/src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/topiclisteners/ObdsXmlTopicMonitor.kt +++ b/src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/topiclisteners/ObdsXmlTopicMonitor.kt @@ -26,7 +26,7 @@ class ObdsXmlTopicMonitor( statisticsEventProducer: StatisticsSink, ) : TopicMonitor(statisticsEventProducer) { - @KafkaListener(topicPattern = "input.*") + @KafkaListener(topicPattern = "onkostar.MELDUNG_EXPORT.*") override fun handleTopicRecord( @Header(KafkaHeaders.RECEIVED_TOPIC) topic: String, @Header(KafkaHeaders.RECEIVED_TIMESTAMP) timestamp: Long,