Thanks for reporting this issue.
It might have been fixed via
https://issues.apache.org/jira/browse/KAFKA-14294 already.
-Matthias
On 12/3/22 7:05 PM, Colt McNealy wrote:
Hi all,
I believe I've found a bug in Kafka Streams when:
- Running an app in EOS
- Calling KeyValueStore::delete(...) on a nonexistent key
- Can cause a ProducerFencedException
The expected behavior is that the call to delete() returns null (as per the
javadoc) and doesn't cause a ProducerFencedException.
I've created a minimally reproducible example which reliably produces the
bug on my own environment at this repository:
https://github.com/littlehorse-eng/kafka-punctuator-fencing-issue
Could someone please take a look and let me know if you can reliably
reproduce it on your end as well, and if so, how to file a bug?
Thank you,
Colt McNealy
*Founder, LittleHorse.io*
