From 056146e9335ff64a2f1406467214a1f687de3808 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 15 Sep 2023 13:13:35 +0200 Subject: [PATCH] WHATTHEFUCK --- .../de/juplo/kafka/chat/backend/KafkaConfigurationIT.java | 7 +++++++ .../chat/backend/implementation/kafka/KafkaTestUtils.java | 6 +++--- 2 files changed, 10 insertions(+), 3 deletions(-) diff --git a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java index 56695df6..724c4816 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java @@ -62,4 +62,11 @@ class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT { KafkaTestUtils.joinConsumerTasks(consumerTaskRunner); } + + + @TestConfiguration + @Import(KafkaTestUtils.KafkaTestConfiguration.class) + static class KafkaConfigurationITConfiguration + { + } } diff --git a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java index 76196e37..4d86848e 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java +++ b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java @@ -24,10 +24,10 @@ public class KafkaTestUtils @TestConfiguration @EnableConfigurationProperties(ChatBackendProperties.class) @Import(KafkaServicesConfiguration.class) - public static class KafkaTestConfiguration + public static class KafkaTestConfiguration { @Bean - WorkAssignor dataChannelWorkAssignor(DataChannel dataChannel) + public WorkAssignor dataChannelWorkAssignor(DataChannel dataChannel) { return consumer -> { @@ -39,7 +39,7 @@ public class KafkaTestUtils } @Bean - Clock clock() + public Clock clock() { return Clock.systemDefaultZone(); } -- 2.20.1