Guozhang Wang created KAFKA-13356:
-------------------------------------
Summary: 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
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)
