[
https://issues.apache.org/jira/browse/KAFKA-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jukka Karvanen updated KAFKA-8233:
----------------------------------
Summary: Helper class to make it simpler to write test logic with
TopologyTestDriver (was: Helper class to make it simpler to write test logic
TopologyTestDriver)
> Helper class to make it simpler to write test logic with TopologyTestDriver
> ---------------------------------------------------------------------------
>
> Key: KAFKA-8233
> URL: https://issues.apache.org/jira/browse/KAFKA-8233
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Jukka Karvanen
> Priority: Minor
>
> When using TopologyTestDriver you need to call ConsumerRecordFactory to
> create ConsumerRecord passed into pipeInput method to write to topic. Also
> when calling readOutput to consume from topic, you need to provide correct
> Deserializers each time.
> You easily end up writing helper methods in your test classed, but this can
> be avoided when adding generic input and output topic classes.
> This improvement adds TestInputTopic class which wraps TopologyTestDriver
> and ConsumerRecordFactory methods as one class to be used to write to Input
> Topics and TestOutputTopic class which collects TopologyTestDriver reading
> methods and provide typesafe read methods.
>
> Example of how Stream test looks after using this classes:
> [https://github.com/jukkakarvanen/kafka-streams-examples/blob/InputOutputTopic/src/test/java/io/confluent/examples/streams/WordCountLambdaExampleTest.java]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
