This is an automated email from the ASF dual-hosted git repository. bbejeck pushed a commit to branch 2.2 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.2 by this push: new f2ae6e3 Fixes #8198 KStreams testing docs use non-existent method pipe (#6678) f2ae6e3 is described below commit f2ae6e3ca900d963cad46ee4adfbdc928ee68d68 Author: slim <ouert...@gmail.com> AuthorDate: Fri Jul 12 18:06:05 2019 +0300 Fixes #8198 KStreams testing docs use non-existent method pipe (#6678) Minor fix of #8198 apache/kafka-site#210 Reviewers: John Roesler <j...@confluent.io>, Bill Bejeck <bbej...@gmail.com> --- docs/streams/developer-guide/testing.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/streams/developer-guide/testing.html b/docs/streams/developer-guide/testing.html index 026b02b..55a89b0 100644 --- a/docs/streams/developer-guide/testing.html +++ b/docs/streams/developer-guide/testing.html @@ -99,7 +99,7 @@ TopologyTestDriver testDriver = new TopologyTestDriver(topology, props); </p> <pre> ConsumerRecordFactory<String, Integer> factory = new ConsumerRecordFactory<>("input-topic", new StringSerializer(), new IntegerSerializer()); -testDriver.pipe(factory.create("key", 42L)); +testDriver.pipeInput(factory.create("key", 42L)); </pre> <p> To verify the output, the test driver produces <code>ProducerRecord</code>s with key and value type