Renamed test into `StreamStreamInnerJoinTest` -- ALIGN
authorKai Moritz <kai@juplo.de>
Wed, 17 Jul 2024 05:09:42 +0000 (07:09 +0200)
committerKai Moritz <kai@juplo.de>
Wed, 17 Jul 2024 05:12:46 +0000 (07:12 +0200)
src/test/java/de/juplo/kafka/streams/join/stream/stream/StreamStreamInnerJoinTest.java

index 5323663..8ee020a 100644 (file)
@@ -1,4 +1,4 @@
-package de.juplo.kafka.wordcount.counter;
+package de.juplo.kafka.streams.join.stream.stream;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.common.serialization.Serdes;
@@ -17,7 +17,7 @@ import static org.assertj.core.api.Assertions.assertThat;
 
 
 @Slf4j
-public class JoinTopologyTest
+public class StreamStreamInnerJoinTest
 {
   static final Duration WINDOW_SIZE = Duration.ofSeconds(10);
   static final Duration GRACE_PERIOD = Duration.ofSeconds(5);