Hi Matthias,
Here's the repro of the project that has these issues
https://github.com/zveljkovic/kafka-repro.
Please look at the:
Topology definition:
https://github.com/zveljkovic/kafka-repro/blob/master/src/main/java/com/example/demo/DemoApplication.java
FixedKeyProcessor:
https://github.com
Hi, I am using kafka-streams-test-utils and have problem with testing
FixedKeyProcessor [KIP-820
https://cwiki.apache.org/confluence/display/KAFKA/KIP-820%3A+Extend+KStream+process+with+new+Processor+API#KIP820:ExtendKStreamprocesswithnewProcessorAPI-InfrastructureforFixedKeyRecords].
Using mock
