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)
