[KAFKA-2872] Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.0.0
• Fix Version/s: 0.10.0.0
• Component/s: streams
• Assignee: Bill Bejeck
• Reporter: Bill Bejeck
• Created: 21/Nov/15 02:51
• Updated: 22/Feb/17 01:07
• Resolved: 22/Nov/15 02:46

Description

When starting the KafkaStream I get the following Exception:

Exception in thread "main" java.util.NoSuchElementException: id: SINK
at org.apache.kafka.streams.processor.internals.QuickUnion.root(QuickUnion.java:40)
at org.apache.kafka.streams.processor.TopologyBuilder.makeNodeGroups(TopologyBuilder.java:387)
at org.apache.kafka.streams.processor.TopologyBuilder.topicGroups(TopologyBuilder.java:339)
at org.apache.kafka.streams.processor.internals.StreamThread.<init>(StreamThread.java:139)
at org.apache.kafka.streams.processor.internals.StreamThread.<init>(StreamThread.java:120)
at org.apache.kafka.streams.KafkaStreaming.<init>(KafkaStreaming.java:110)
at bbejeck.ProcessorDriver.main(ProcessorDriver.java:35)

The TopologyBuilder is being built like so:
topologyBuilder.addSource("SOURCE", new StringDeserializer(), new StringDeserializer(), "src-topic")
.addProcessor("PROCESS", new GenericProcessorClient(replaceVowels), "SOURCE")
.addSink("SINK", "dest-topic", new StringSerializer(), new StringSerializer(), "PROCESS");

Looks to me the cause of the error is that in TopologyBuilder.addSink method the sink is never connected with it's parent.