[jira] [Updated] (KAFKA-14388) NPE When Retrieving StateStore with new Processor API
[ https://issues.apache.org/jira/browse/KAFKA-14388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-14388: Component/s: streams > NPE When Retrieving StateStore with new Processor API > - > > Key: KAFKA-14388 > URL: https://issues.apache.org/jira/browse/KAFKA-14388 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 3.3.0, 3.3.1 >Reporter: Bill Bejeck >Assignee: Bill Bejeck >Priority: Major > Fix For: 3.4.0, 3.3.2 > > > Using the new Processor API introduced with KIP-820 when adding a state store > to the Processor when executing `context().getStore("store-name")` always > returns `null` as the store is not in the `stores` `HashMap` in the > `ProcessorStateManager`. This occurs even when using the > `ConnectedStoreProvider.stores()` method > I've confirmed the store is associated with the processor by viewing the > `Topology` description. > From some initial triage, it looks like the store is never registered. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-14388) NPE When Retrieving StateStore with new Processor API
[ https://issues.apache.org/jira/browse/KAFKA-14388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-14388: Fix Version/s: 3.3.2 > NPE When Retrieving StateStore with new Processor API > - > > Key: KAFKA-14388 > URL: https://issues.apache.org/jira/browse/KAFKA-14388 > Project: Kafka > Issue Type: Bug >Affects Versions: 3.3.0, 3.3.1 >Reporter: Bill Bejeck >Assignee: Bill Bejeck >Priority: Major > Fix For: 3.4.0, 3.3.2 > > > Using the new Processor API introduced with KIP-820 when adding a state store > to the Processor when executing `context().getStore("store-name")` always > returns `null` as the store is not in the `stores` `HashMap` in the > `ProcessorStateManager`. This occurs even when using the > `ConnectedStoreProvider.stores()` method > I've confirmed the store is associated with the processor by viewing the > `Topology` description. > From some initial triage, it looks like the store is never registered. -- This message was sent by Atlassian Jira (v8.20.10#820010)