Description
The internal store handling in Streams has become quite complex, with many layers of wrapping for different bookeeping operations.
The first thing we can do about this is to at least unify the wrapping strategy, such that all store wrappers extend WrappedStateStore. This would make the code easier to understand, since all wrappers would have the same basic shape.
Attachments
Issue Links
- relates to
-
KAFKA-7917 Streams store cleanup: collapse layers
-
- Closed
-
- links to