[kafka] branch trunk updated: Fixes #8198 KStreams testing docs use non-existent method pipe (#6678)

[bb...@apache.org]

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 <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&lt;String, Integer&gt; factory = new ConsumerRecordFactory&lt;&gt;("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