diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java b/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java index abb5aa1bbd95c..609bce5caabaa 100644 --- a/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java +++ b/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java @@ -507,7 +507,9 @@ public synchronized StreamsBuilder addGlobalStore(final StoreBuilder storeBuilde * of the input topic. *

* The provided {@link ProcessorSupplier} will be used to create an {@link ProcessorNode} that will receive all - * records forwarded from the {@link SourceNode}. + * records forwarded from the {@link SourceNode}. NOTE: you should not use the {@code Processor} to insert transformed records into + * the global state store. This store uses the source topic as changelog and during restore will insert records directly + * from the source. * This {@link ProcessorNode} should be used to keep the {@link StateStore} up-to-date. * The default {@link TimestampExtractor} as specified in the {@link StreamsConfig config} is used. *