[
https://issues.apache.org/jira/browse/KAFKA-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jukka Karvanen updated KAFKA-8233:
----------------------------------
Description:
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 improvement deprecates the old TopologyTestDriver input and output methods
in favor of TestInputTopic and TestOutputTopic classes. Also now obsoleted
ConsumerRecordFactory and OutputVerifier classes are deprecated.
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]
was:
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]
> 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 improvement deprecates the old TopologyTestDriver input and output
> methods in favor of TestInputTopic and TestOutputTopic classes. Also now
> obsoleted ConsumerRecordFactory and OutputVerifier classes are deprecated.
> 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)
