Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8198

KStreams testing docs use non-existent method "pipe"

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      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.

        Attachments

          Activity

            People

            • Assignee:
              ouertani Slim Ouertani
              Reporter:
              mdrogalis Michael Drogalis

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment