[ https://issues.apache.org/jira/browse/KAFKA-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608655#comment-16608655 ]
Matthias J. Sax commented on KAFKA-4587: ---------------------------------------- [~guozhang] I think we should move this to fixed version 2.2.0 ? > Rethink Unification of Caching with Dedupping > --------------------------------------------- > > Key: KAFKA-4587 > URL: https://issues.apache.org/jira/browse/KAFKA-4587 > Project: Kafka > Issue Type: Bug > Components: streams > Reporter: Guozhang Wang > Priority: Major > Fix For: 2.1.0 > > > This is discussed in PR https://github.com/apache/kafka/pull/1588 > In order to support user-customizable state store suppliers in the DSL we did > the following: > 1) Introduce a {{TupleForwarder}} to forward tuples from cached stores that > is wrapping user customized stores. > 2) Narrow the scope to only dedup on forwarding if it is the default > CachingXXStore with wrapper RocksDB. > With this, the unification of dedupping and caching is less useful now, and > we are complicating the inner implementations for forwarding a lot. We need > to re-consider this feature with finer granularity of turning on / off > caching per store, potentially with explicit triggers. -- This message was sent by Atlassian JIRA (v7.6.3#76005)