WHATTHEFUCK
authorKai Moritz <kai@juplo.de>
Fri, 15 Sep 2023 11:13:35 +0000 (13:13 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 15 Sep 2023 11:17:55 +0000 (13:17 +0200)
src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java
src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java

index 56695df..724c481 100644 (file)
@@ -62,4 +62,11 @@ class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT
   {
     KafkaTestUtils.joinConsumerTasks(consumerTaskRunner);
   }
+
+
+  @TestConfiguration
+  @Import(KafkaTestUtils.KafkaTestConfiguration.class)
+  static class KafkaConfigurationITConfiguration
+  {
+  }
 }
index 76196e3..4d86848 100644 (file)
@@ -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();
     }