GitHub user mewwts opened a pull request: https://github.com/apache/kafka/pull/3992
MINOR: Allow schedule and commit in MockProcessorContext This change allows for testing custom Processors and Transformers that call `schedule` and `commit` using KStreamTestDriver, by _not_ throwing `UnsupportedOperationException`. This PR is my original work. You can merge this pull request into a Git repository by running: $ git pull https://github.com/mewwts/kafka allow-schedule-and-commit Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3992.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3992 ---- commit a8a4186613cf59caf65089e8b6922e62c11503d0 Author: Mats Julian Olsen <m...@plysjbyen.net> Date: 2017-09-29T12:11:27Z MINOR: Allow schedule and commit in MockProcessorContext ---- ---