Not sure right now, but could be a bug. Can you maybe share the full stack trace and the test program?
-Matthias On 7/10/23 3:47 AM, EXT.Zlatibor.Veljkovic wrote:
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 processor context to get the forwarded message doesn't work. class org.apache.kafka.streams.processor.api.MockProcessorContext cannot be cast to class org.apache.kafka.streams.processor.api.FixedKeyProcessorContext Anything I can do to get forwarded records? Thanks, Zed
