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

KStreams testing docs use non-existent method "pipe"

    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

          Issue Links

            Activity

              People

              • Assignee:
                ouertani Slim Ouertani
                Reporter:
                mdrogalis Michael Drogalis
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: