[
https://issues.apache.org/jira/browse/KAFKA-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8233:
-----------------------------------
Labels: needs-kip (was: )
> 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
> Labels: needs-kip
>
> 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.
>
> More info and an example of how Stream test looks after using this classes:
> [https://github.com/jukkakarvanen/kafka-streams-test-topics]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
