diff --git a/streams-text-processor/src/main/java/io/jeffchao/streams/textprocessor/TextProcessor.java b/streams-text-processor/src/main/java/io/jeffchao/streams/textprocessor/TextProcessor.java
index d5c6557..e638f7b 100644
--- a/streams-text-processor/src/main/java/io/jeffchao/streams/textprocessor/TextProcessor.java
+++ b/streams-text-processor/src/main/java/io/jeffchao/streams/textprocessor/TextProcessor.java
@@ -48,15 +48,6 @@ public static void main(String[] args) throws CertificateException, NoSuchAlgori
         .flatMapValues(value -> Arrays.asList(pattern.split(value.toLowerCase())))
         .to(String.format("%swords", TOPIC_PREFIX), Produced.with(stringSerde, stringSerde));
 
-    //    final KTable<String, Long> wordCounts = textLines
-    //        .flatMapValues(value -> Arrays.asList(pattern.split(value.toLowerCase())))
-    //        .groupBy((key, word) -> word)
-    //        .count(Materialized.as("counts"));
-
-    //    wordCounts.toStream()
-    //        .to(String.format("%swordswithcounts", TOPIC_PREFIX),
-    //            Produced.with(stringSerde, longSerde));
-
     final KafkaStreams streams = new KafkaStreams(builder.build(), streamsConfig);
 
     streams.cleanUp();