From 3e45bf84940b1e94c642bf3a88e94514e5a83c41 Mon Sep 17 00:00:00 2001 From: Paul-Christian Volkmer Date: Thu, 29 Feb 2024 09:19:32 +0100 Subject: feat: implement KafkaInputListener --- .../kotlin/dev/dnpm/etl/processor/config/AppConfigurationTest.kt | 2 ++ 1 file changed, 2 insertions(+) (limited to 'src/integrationTest') diff --git a/src/integrationTest/kotlin/dev/dnpm/etl/processor/config/AppConfigurationTest.kt b/src/integrationTest/kotlin/dev/dnpm/etl/processor/config/AppConfigurationTest.kt index 46a756b..262aca0 100644 --- a/src/integrationTest/kotlin/dev/dnpm/etl/processor/config/AppConfigurationTest.kt +++ b/src/integrationTest/kotlin/dev/dnpm/etl/processor/config/AppConfigurationTest.kt @@ -26,6 +26,7 @@ import dev.dnpm.etl.processor.output.KafkaMtbFileSender import dev.dnpm.etl.processor.output.RestMtbFileSender import dev.dnpm.etl.processor.pseudonym.AnonymizingGenerator import dev.dnpm.etl.processor.pseudonym.GpasPseudonymGenerator +import dev.dnpm.etl.processor.services.RequestProcessor import dev.dnpm.etl.processor.services.TokenRepository import dev.dnpm.etl.processor.services.TokenService import org.assertj.core.api.Assertions.assertThat @@ -144,6 +145,7 @@ class AppConfigurationTest { "app.kafka.group-id=test" ] ) + @MockBean(RequestProcessor::class) inner class AppConfigurationUsingKafkaInputTest(private val context: ApplicationContext) { @Test -- cgit v1.2.3