diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java index b1d60a9ad886c..bfe8cda7da133 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java @@ -712,6 +712,10 @@ private void addGlobalStore(final String sourceName, private void connectProcessorAndStateStore(final String processorName, final String stateStoreName) { + if (globalStateStores.containsKey(stateStoreName)) { + throw new TopologyException("Global StateStore " + stateStoreName + + " can be used by a Processor without being specified; it should not be explicitly passed."); + } if (!stateFactories.containsKey(stateStoreName)) { throw new TopologyException("StateStore " + stateStoreName + " is not added yet."); }