From: Kai Moritz Date: Wed, 17 Jul 2024 06:02:09 +0000 (+0200) Subject: Renamed test into `AggregateWindowedTumblingTest` -- ALIGN X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=92edfb68e9a30149720d392d4474db32fc35550b;p=demos%2Fkafka%2Fwordcount Renamed test into `AggregateWindowedTumblingTest` -- ALIGN --- diff --git a/src/test/java/de/juplo/kafka/streams/aggregate/windowed/tumbling/AggregateWindowedTumblingTest.java b/src/test/java/de/juplo/kafka/streams/aggregate/windowed/tumbling/AggregateWindowedTumblingTest.java index 85fb265..9283e0e 100644 --- a/src/test/java/de/juplo/kafka/streams/aggregate/windowed/tumbling/AggregateWindowedTumblingTest.java +++ b/src/test/java/de/juplo/kafka/streams/aggregate/windowed/tumbling/AggregateWindowedTumblingTest.java @@ -1,4 +1,4 @@ -package de.juplo.kafka.wordcount.counter; +package de.juplo.kafka.streams.aggregate.windowed.tumbling; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.common.serialization.Serdes; @@ -22,7 +22,7 @@ import static org.assertj.core.api.Assertions.assertThat; @Slf4j -public class AggregationTopologyTest +public class AggregateWindowedTumblingTest { static final Duration WINDOW_SIZE = Duration.ofSeconds(10); static final TimeWindows WINDOWS = TimeWindows.ofSizeWithNoGrace(WINDOW_SIZE);