Robert Yokota created KAFKA-6894: ------------------------------------ Summary: Cannot access GlobalKTable store from KStream.transform() Key: KAFKA-6894 URL: https://issues.apache.org/jira/browse/KAFKA-6894 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 1.1.0 Reporter: Robert Yokota Assignee: Robert Yokota
I was trying to access a store from a {{GlobalKTable}} in {{KStream.transform()}}, but I got the following error: {code} org.apache.kafka.streams.errors.TopologyException: Invalid topology: StateStore globalStore is not added yet. at org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.connectProcessorAndStateStore(InternalTopologyBuilder.java:716) at org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.connectProcessorAndStateStores(InternalTopologyBuilder.java:615) at org.apache.kafka.streams.kstream.internals.KStreamImpl.transform(KStreamImpl.java:521) {code} I was able to make a change to {{InternalTopologyBuilder.connectProcessorAndState}} to allow me to access the global store from {{KStream.transform()}}. I will submit a PR for review. -- This message was sent by Atlassian JIRA (v7.6.3#76005)