[KAFKA-8198] KStreams testing docs use non-existent method "pipe"

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.1.1, 2.0.1, 2.2.0, 2.1.1
• Fix Version/s: 1.1.0, 2.0.0, 2.1.0, 2.2.0, 2.3.0, 2.4.0
• Component/s: documentation, streams
• Labels: documentation newbie
• Assignee: Slim Ouertani
• Reporter: Michael Drogalis
• Created: 05/Apr/19 20:35
• Updated: 12/Jul/19 15:26
• Resolved: 12/Jul/19 15:11

Description

In the testing docs for KStreams, we use the following code snippet:

ConsumerRecordFactory<String, Integer> factory = new ConsumerRecordFactory<>("input-topic", new StringSerializer(), new IntegerSerializer());
testDriver.pipe(factory.create("key", 42L));

We should correct the docs to use the pipeInput method.

Issue Links

• links to: Pull request
• links to: Pull request