kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbej...@apache.org
Subject [kafka] branch 2.2 updated: Fixes #8198 KStreams testing docs use non-existent method pipe (#6678)
Date Fri, 12 Jul 2019 15:13:01 GMT
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 <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 | 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


Mime
View raw message