X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterStreamProcessor.java;h=4d3bcc436f437964152284e865fd058627e8a2ee;hb=fe049944648d9675ffe66b586b6bf860fbac696f;hp=e8d7c116ffb8550a257955c825d878f7a6c4cb2b;hpb=b1623c2b645c614424ceec3bc71008c900d82115;p=demos%2Fkafka%2Fwordcount

diff --git a/src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java b/src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java
index e8d7c11..4d3bcc4 100644
--- a/src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java
+++ b/src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java
@@ -16,10 +16,8 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.PostConstruct;
 import javax.annotation.PreDestroy;
-import java.util.Arrays;
 import java.util.Properties;
 import java.util.concurrent.CompletableFuture;
-import java.util.regex.Pattern;
 
 import static org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse.SHUTDOWN_CLIENT;
 
@@ -28,8 +26,6 @@ import static org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler.St
 @Component
 public class CounterStreamProcessor
 {
-	final static Pattern PATTERN = Pattern.compile("\\W+");
-
 	public final KafkaStreams streams;
 
 
@@ -42,7 +38,6 @@ public class CounterStreamProcessor
 
 		KStream<String, String> source = builder.stream(properties.getInputTopic());
 		source
-				.flatMapValues(sentence -> Arrays.asList(PATTERN.split(sentence)))
 				.map((username, word) ->
 				{
 					try