Hi, I've put together a KIP to make some changes to the KafkaStreams DSL that will hopefully allow us to: 1) reduce the explosion of overloads 2) add new features without having to continue adding more overloads 3) provide simpler ways for people to use custom storage engines and wrap them with logging, caching etc if desired 4) enable per-operator caching rather than global caching without having to resort to supplying a StateStoreSupplier when you just want to turn caching off.
The KIP is here: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=73631309 Thanks, Damian
