mfenniak

    fun printGraphviz(builder: TopologyBuilder) {
        println("digraph {")

        val nodeGroups = builder.nodeGroups()
        val processorTopologys = nodeGroups.map { kv ->  builder.build(kv.key) }

        val sourceTopics = processorTopologys.flatMap { it.sourceTopics() }
        val sinkTopics = processorTopologys.flatMap { it.sinkTopics() }
        val allTopics = sourceTopics.plus(sinkTopics).distinct().sorted()
        println("  node [shape=\"rect\"]")