[KAFKA-6894] Improve error message when connecting processor with a global store

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.1.0
• Fix Version/s: 2.0.0
• Component/s: streams
• Assignee: Robert Yokota
• Reporter: Robert Yokota
• Created: 10/May/18 19:14
• Updated: 10/May/18 22:49
• Resolved: 10/May/18 22:49

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.

Issue Links

• links to: GitHub Pull Request #5000