[KAFKA-6721] Consolidate state store management for global stores and normal stores

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: streams
• Assignee: Unassigned
• Reporter: Guozhang Wang
• Created: 27/Mar/18 23:05
• Updated: 01/Mar/19 08:10

Description

Today the internal logic of handling global state store restoration and update, and normal store restoration are separated in two set of classes. Hence whenever we are updating the logic for one of it we need to do the same for others, which we may easily forget, causing regressions.

As a tech debt cleanup we should consider consolidating the logic of global state stores into `StateRestorer` and `StoreChangelogReader` if possible.

Issue Links

• relates to: KAFKA-8023 Improve global state store restoration by using multiple update threads