Wim Van Leuven created KAFKA-4927:
-------------------------------------
Summary: KStreamsTestDriver fails with NullPointerException when
Topic sinks are used
Key: KAFKA-4927
URL: https://issues.apache.org/jira/browse/KAFKA-4927
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 0.10.2.0
Reporter: Wim Van Leuven
Fix For: 0.10.2.0
*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*
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
