Hello all, I've been slowly pushing KIP-478 forward over the last year, and I'm happy to say that we're making good progress now. However, several issues with the original design have come to light.
The major changes: We discovered that the original plan of just adding generic parameters to ProcessorContext was too disruptive, so we are now adding a new api.ProcessorContext. That choice forces us to add a new StateStore.init method for the new context, but ProcessorContext really isn't ideal for state stores to begin with, so I'm proposing a new StateStoreContext for this purpose. In a nutshell, there are quite a few methods in ProcessorContext that actually should never be called from inside a StateStore. Also, since there is a new ProcessorContext interface, we need a new MockProcessorContext implementation in the test- utils module. The changeset for the KIP document is here: https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=118172121&selectedPageVersions=14&selectedPageVersions=10 And the KIP itself is here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-478+-+Strongly+typed+Processor+API If you have any concerns, please let me know! Thanks, -John
