Are stateful transducers atop `org.apache.kafka.streams.state` implemented, or planned?
Opened this issue · 0 comments
blak3mill3r commented
In the README, it says
This library also provides a number of stateful transducers over Kafka Streams' Stores API for doing joins,
windowed aggregates, etc. The goal of this library is to maintain feature parity with the high-level KStream,
KTable, etc. APIs, as well as (eventually) to enable transducer usage in the low-level Processor API.
If this implemented in master
right now, it was not obvious to me.
Although I see some things that look like building-blocks for the above idea (KeyValueTupleIterator
, IReadOnlyKeyValueStore
), I did not see any definitions of stateful transducers using those primitives, and no test or example code with kafka-backed stateful transducers.
I think this has the potential to be very powerful. If it is not implemented yet, I think I'll have a crack at it, but I wanted to ask for clarification first. I'd be happy to chat about it, too.