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");