This is an automated email from the ASF dual-hosted git repository. bbejeck pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new 8cabd44 Fixes #8198 KStreams testing docs use non-existent method pipe (#6678) 8cabd44 is described below commit 8cabd44e1d35d3cf3f865d8a4eee8c04228e0d75 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