[KAFKA-7075] Allow Topology#addGlobalStore to add a window store

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: streams
• Labels: newbie
• Assignee: Unassigned
• Reporter: Guozhang Wang
• Created: 19/Jun/18 22:49
• Updated: 29/Dec/22 00:32

Description

Today although Topology#addGlobalStore can take any StateStore types, the internal implementation InternalTopologyBuilder#addGlobalStore only accepts StoreBuilder<KeyValueStore>. It means if users pass in a windowed store builder in Topology#addGlobalStore it will cause a runtime ClassCastException.

We should fix this issue by relaxing the InternalTopologyBuilder.

Issue Links

• links to: GitHub Pull Request #5725