comment re: topology logging

kissaten · Oct 15, 2019 · 00f21f5 · 00f21f5
1 parent 9f86af1
commit 00f21f5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/streams-aggregator/src/main/java/io/jeffchao/streams/aggregator/Aggregator.java b/streams-aggregator/src/main/java/io/jeffchao/streams/aggregator/Aggregator.java
@@ -48,6 +48,9 @@ public static void main(String[] args) throws CertificateException, NoSuchAlgori
         .process(PostgresSink::new);
 
     final Topology topology = builder.build();
+
+    // Log topology at startup, for debugging
+    // More about the topology graph: https://www.confluent.io/blog/optimizing-kafka-streams-applications
     System.out.println(topology.describe());
 
     final KafkaStreams streams = new KafkaStreams(topology, streamsConfig);