kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbej...@apache.org
Subject [kafka] branch 1.1 updated: Fixes #8198 KStreams testing docs use non-existent method pipe (#6678)
Date Fri, 12 Jul 2019 15:25:11 GMT
This is an automated email from the ASF dual-hosted git repository.

bbejeck pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/1.1 by this push:
     new cf3f9ac  Fixes #8198 KStreams testing docs use non-existent method pipe (#6678)
cf3f9ac is described below

commit cf3f9ac4ea1bc40f014ae93a6dc197f60834ff66
Author: slim <ouertani@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 <john@confluent.io>, Bill Bejeck <bbejeck@gmail.com>
---
 docs/streams/developer-guide/testing.html | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/docs/streams/developer-guide/testing.html b/docs/streams/developer-guide/testing.html
index e6886a1..c3dc0a8 100644
--- a/docs/streams/developer-guide/testing.html
+++ b/docs/streams/developer-guide/testing.html
@@ -76,12 +76,14 @@ TopologyTestDriver testDriver = new TopologyTestDriver(topology, config);
     </p>
     <pre>
 ConsumerRecordFactory&lt;String, Integer&gt; factory = new ConsumerRecordFactory&lt;&gt;("input-topic",
new StringSerializer(), new IntegerSerializer());
-testDriver.pipe(factory.create("key", 42L));
-    </pre>
-    <p>
-    To verify the output, the test driver produces <code>ProducerRecord</code>s
with key and value type <code>byte[]</code>.
-    For result verification, you can specify corresponding deserializers when reading the
output record from the driver.
-    <pre>
+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
+                <code>byte[]</code>.
+                For result verification, you can specify corresponding deserializers when
reading the output record from
+                the driver.
+            <pre>
 ProducerRecord&lt;String, Integer&gt; outputRecord = testDriver.readOutput("output-topic",
new StringDeserializer(), new LongDeserializer());
     </pre>
     <p>


Mime
View raw message