[KAFKA-4927] KStreamsTestDriver fails with NPE when KStream.to() sinks are used

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.2.0
• Fix Version/s: 0.11.0.0
• Component/s: streams
• Labels: test
• Assignee: Wim Van Leuven
• Reporter: Wim Van Leuven
• Created: 21/Mar/17 14:06
• Updated: 09/May/17 21:33
• Resolved: 09/May/17 21:32

Description

Context
KStreamsTestDriver allows to build integration tests of KStreamsTopologies. This also includes topologies that sink data into outgoing topics by calling the KStream.to() methods.

Problem
When a topic is added as a sink, the KStreamsTestDriver fails with NullPointerExceptions.

Solution
BugFix the method KStreamTestDriver.process() method to also lookup a topic by topicName as a sink when a source has not been found.

PullRequest

Issue Links

• links to: GitHub Pull Request #2716