From fe5049220c9c5dcbed468d569c403efb7f5ded64 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 8 Jul 2024 09:23:37 +0200 Subject: [PATCH] Renaming for demonstration of an aggregation -- ALIGN --- pom.xml | 4 ++-- .../kafka/wordcount/counter/AggregationTopologyTest.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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() -- 2.20.1