Skip to content

Instantly share code, notes, and snippets.

@songyunlu

songyunlu/TopologyBuilder.java

Created March 12, 2017 02:51
Show Gist options
  • Save songyunlu/d92244e9ce874556df1d06b72cf590c4 to your computer and use it in GitHub Desktop.
Save songyunlu/d92244e9ce874556df1d06b72cf590c4 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
TopologyBuilder.java
TopologyBuilder builder = new TopologyBuilder();
builder.addSource("SOURCE", "src-topic")
.addProcessor("PROCESS1", () -> new MyProcessor1(), "SOURCE")
.addProcessor("PROCESS2", () -> new MyProcessor2(), "PROCESS1")
.addProcessor("PROCESS3", () -> new MyProcessor3(), "PROCESS1")
.addSink("SINK1", "sink-topic1", "PROCESS1")
.addSink("SINK2", "sink-topic2", "PROCESS2")
.addSink("SINK3", "sink-topic3", "PROCESS3");
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment