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_
GitHub user mewwts opened a pull request:
https://github.com/apache/kafka/pull/3999
MINOR: Add attributes `processedKeys` and `processedValues` to
MockProcessorSupplier
This would allow for easier testing of topologies using the following
pattern:
```Scala
// in Scala
