You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by bb...@apache.org on 2019/07/12 15:12:37 UTC
[kafka] branch 2.3 updated: Fixes #8198 KStreams testing docs use
non-existent method pipe (#6678)
This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a commit to branch 2.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push:
new 62617b9 Fixes #8198 KStreams testing docs use non-existent method pipe (#6678)
62617b9 is described below
commit 62617b93d13215716600aa498f6806978be07c30
Author: slim <ou...@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 <jo...@confluent.io>, Bill Bejeck <bb...@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