[jira] [Assigned] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store
[ https://issues.apache.org/jira/browse/KAFKA-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7075: -- Assignee: (was: Nishanth Pradeep) > Allow Topology#addGlobalStore to add a window store > --- > > Key: KAFKA-7075 > URL: https://issues.apache.org/jira/browse/KAFKA-7075 > Project: Kafka > Issue Type: Bug > Components: streams >Reporter: Guozhang Wang >Priority: Major > Labels: newbie > > Today although {{Topology#addGlobalStore}} can take any {{StateStore}} types, > the internal implementation {{InternalTopologyBuilder#addGlobalStore}} only > accepts {{StoreBuilder}}. 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}}. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store
[ https://issues.apache.org/jira/browse/KAFKA-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-7075: Assignee: Nishanth Pradeep > Allow Topology#addGlobalStore to add a window store > --- > > Key: KAFKA-7075 > URL: https://issues.apache.org/jira/browse/KAFKA-7075 > Project: Kafka > Issue Type: Bug > Components: streams >Reporter: Guozhang Wang >Assignee: Nishanth Pradeep >Priority: Major > Labels: newbie > > Today although {{Topology#addGlobalStore}} can take any {{StateStore}} types, > the internal implementation {{InternalTopologyBuilder#addGlobalStore}} only > accepts {{StoreBuilder}}. 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}}. -- This message was sent by Atlassian JIRA (v7.6.3#76005)