[
https://issues.apache.org/jira/browse/KAFKA-13356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13356:
---------------------------------------
Assignee: Matthias J. Sax
> Use "delete" retention policy only for stream-stream join windowed stores
> -------------------------------------------------------------------------
>
> Key: KAFKA-13356
> URL: https://issues.apache.org/jira/browse/KAFKA-13356
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Guozhang Wang
> Assignee: Matthias J. Sax
> Priority: Major
>
> Today stream-stream join associated window stores, like any other window
> stores, use "delete,compact" as their retention policies. However, since
> today we add sequence number to disable de-duplication of keys, "compaction"
> would never be able to compact any keys, but only result in 1) CPU waste on
> the cleaner thread on brokers, 2) some additional feature of brokers that
> relies on "delete" policy to not be able to apply.
> Until we change the store format potentially in the future to not use
> sequence number for disable de-duping, we could consider just changing the
> policy to "delete" for stream-stream join's window store for now.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
