kafka-commits mailing list archives

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

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


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

commit 8cc43fa313a97d929eca61e45a887cf802e4e0ac
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 bdecc43..9ede7ea 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