From: Kai Moritz Date: Fri, 15 Sep 2023 09:56:05 +0000 (+0200) Subject: WIP:ALIGN X-Git-Tag: rebase--2023-09-15--16-33~14 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=b890eb5c9fd07363bee937be43bab6fd47ae8900;p=demos%2Fkafka%2Fchat WIP:ALIGN --- 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 5183d146..be1d7065 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 @@ -32,10 +32,10 @@ public abstract class KafkaTestUtils "chat.backend.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}", "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}", }) - static class KafkaTestConfiguration + public static class KafkaTestConfiguration { @Bean - WorkAssignor dataChannelWorkAssignor(DataChannel dataChannel) + public WorkAssignor dataChannelWorkAssignor(DataChannel dataChannel) { return consumer -> { @@ -47,7 +47,7 @@ public abstract class KafkaTestUtils } @Bean - Clock clock() + public Clock clock() { return Clock.systemDefaultZone(); }