import topology into corret file

kissaten · Oct 2, 2019 · 7479512 · 7479512
1 parent 04d5303
commit 7479512
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
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
@@ -16,6 +16,7 @@
 import org.apache.kafka.streams.kstream.Materialized;
 import org.apache.kafka.streams.kstream.TimeWindows;
 import org.apache.kafka.streams.kstream.Windowed;
+import org.apache.kafka.streams.Topology;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

diff --git a/streams-aggregator/src/main/java/io/jeffchao/streams/aggregator/sinks/PostgresSink.java b/streams-aggregator/src/main/java/io/jeffchao/streams/aggregator/sinks/PostgresSink.java
@@ -11,7 +11,6 @@
 import org.apache.kafka.streams.kstream.Windowed;
 import org.apache.kafka.streams.processor.Processor;
 import org.apache.kafka.streams.processor.ProcessorContext;
-import org.apache.kafka.streams;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;