From: Kai Moritz Date: Mon, 8 Jul 2024 07:23:37 +0000 (+0200) Subject: Renaming for demonstration of an aggregation -- ALIGN X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=fe5049220c9c5dcbed468d569c403efb7f5ded64;p=demos%2Fkafka%2Fwordcount Renaming for demonstration of an aggregation -- ALIGN --- diff --git a/pom.xml b/pom.xml index 6063371..0a2d335 100644 --- a/pom.xml +++ b/pom.xml @@ -12,10 +12,10 @@ de.juplo.kafka.streams.demos - stream-stream--inner-join + aggregate 1.0.0-SNAPSHOT - Outcome of an Inner Stream/Stream-Join + Outcome of an Aggregation 21 diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/AggregationTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/counter/AggregationTopologyTest.java index f34dfbe..fd0ae85 100644 --- a/src/test/java/de/juplo/kafka/wordcount/counter/AggregationTopologyTest.java +++ b/src/test/java/de/juplo/kafka/wordcount/counter/AggregationTopologyTest.java @@ -20,7 +20,7 @@ import static org.assertj.core.api.Assertions.assertThat; @Slf4j -public class StreamStreamJoinTopologyTest +public class AggregationTopologyTest { @Test public void test()