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/zveljkovic/kafka-repro/blob/master/src/main/java/com/example/demo/MyFixedKeyProcessor.java Test of FixedKeyProcessor: https://github.com/zveljkovic/kafka-repro/blob/master/src/test/java/com/example/demo/MyFixedKeyProcessorTest.java Test is where I am having issues. Thanks, Zed -----Original Message----- From: Matthias J. Sax <mj...@apache.org> Sent: Tuesday, July 11, 2023 1:13 AM To: dev@kafka.apache.org Subject: Re: Testing FixedKeyProcessor implementation using unit tests External email:Be careful with links and attachments 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 >
