From df96d765b632bf754ec4ff09ebe9f4e2a239c220 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 17 Jul 2024 07:09:42 +0200 Subject: [PATCH] Renamed test into `StreamStreamInnerJoinTest` -- ALIGN --- .../streams/join/stream/stream/StreamStreamInnerJoinTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/java/de/juplo/kafka/streams/join/stream/stream/StreamStreamInnerJoinTest.java b/src/test/java/de/juplo/kafka/streams/join/stream/stream/StreamStreamInnerJoinTest.java index 5323663..8ee020a 100644 --- a/src/test/java/de/juplo/kafka/streams/join/stream/stream/StreamStreamInnerJoinTest.java +++ b/src/test/java/de/juplo/kafka/streams/join/stream/stream/StreamStreamInnerJoinTest.java @@ -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); -- 2.20.1