Thanks for filing a ticket for it:
https://issues.apache.org/jira/browse/KAFKA-15242
On 7/14/23 1:06 AM, EXT.Zlatibor.Veljkovic wrote:
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
