You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Michael Drogalis (JIRA)" <ji...@apache.org> on 2019/04/05 20:36:00 UTC
[jira] [Created] (KAFKA-8198) KStreams testing docs use
non-existent method "pipe"
Michael Drogalis created KAFKA-8198:
---------------------------------------
Summary: KStreams testing docs use non-existent method "pipe"
Key: KAFKA-8198
URL: https://issues.apache.org/jira/browse/KAFKA-8198
Project: Kafka
Issue Type: Bug
Reporter: Michael Drogalis
In [the testing docs for KStreams|https://kafka.apache.org/20/documentation/streams/developer-guide/testing.html], we use the following code snippet:
{code:java}
ConsumerRecordFactory<String, Integer> factory = new ConsumerRecordFactory<>("input-topic", new StringSerializer(), new IntegerSerializer());
testDriver.pipe(factory.create("key", 42L));
{code}
As of Apache Kafka 2.2.0, this method no longer exists. We should correct the docs to use the pipeInput method.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)