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

Add mocks for state stores used in Streams unit testing

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: streams-test-utils
    • Labels:

      Description

      We'd like to use mocks for different types of state stores: kv, window, session that can be used to record the number of expected put / get calls used in the DSL operator unit testing. This involves implementing the two interfaces StoreSupplier and StoreBuilder that can return a object created from, say, EasyMock, and the object can then be set up with the expected calls.

      In addition, we should also add a mock record collector which can be returned from the mock processor context so that with logging enabled store, users can also validate if the changes have been forwarded to the changelog as well.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                shung Yishun Guan
                Reporter:
                guozhang Guozhang Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated: