[
https://issues.apache.org/jira/browse/KAFKA-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jukka Karvanen updated KAFKA-8233:
----------------------------------
Summary: KIP-470: TopologyTestDriver test input and output usability
improvements (was: Helper classes to make it simpler to write test logic with
TopologyTestDriver)
> KIP-470: TopologyTestDriver test input and output usability improvements
> ------------------------------------------------------------------------
>
> Key: KAFKA-8233
> URL: https://issues.apache.org/jira/browse/KAFKA-8233
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Jukka Karvanen
> Assignee: Jukka Karvanen
> Priority: Minor
> Labels: kip
> Fix For: 2.4.0
>
>
> 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.
> This is KIP:
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-470%3A+TopologyTestDriver+test+input+and+output+usability+improvements]
>
>
> 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
(v8.3.4#803005)
