Description
I was trying to access a store from a GlobalKTable in KStream.transform(), but I got the following error:
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)
I have submitted a PR to improve the error message.
Attachments
Issue Links
- links to