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

Rewrite KStreamPeekTest at processor level avoiding driver usage

    Details

    • Type: Test
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.0.0
    • Component/s: streams
    • Labels:
      None

      Description

      Hi,
      as already done for the KStreamPrintTest we could remove the usage of KStreamTestDriver even in the KStreamPeekTest and testing it at processor level not at stream level.
      My proposal is to :

      • create the KStreamPeek instance providing the action which fill a collection as already happens today
      • testing for both forwardDownStream values true and false
      • using the MockProcessorContext class for overriding the forward method filling a streamObserved collection as happens today forwardDownStream is true; checking that the forward isn't called when forwardDownStream is false (so the test fails)

      Thanks,
      Paolo

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                ppatierno Paolo Patierno
                Reporter:
                ppatierno Paolo Patierno
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: