Topology DAG shows duplicate nodes when there are multiple input topics

[IndeedSi]

The Streams Topology definition

       @Override
        public Topology topology() {
            final StreamsBuilder builder = new StreamsBuilder();

            final KStream<String, String> source = builder.stream(Arrays.asList(
                    "streams-plaintext-input",
                    "streams-plaintext-input2"
            ));

            final KTable<String, Long> counts = source
                    .flatMapValues(value -> Arrays.asList(value.toLowerCase().split("\\W+")))
                    .groupBy((key, value) -> value)
                    .count(Materialized.as("count"));

            counts.toStream().to("streams-wordcount-output", Produced.with(Serdes.String(), Serdes.Long()));

            return builder.build();
        }

[fhussonnois]

Hi @IndeedSi thank you so much for your PR. I really appreciate!