THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!

Page History

Versions Compared

Key

This line was added.
This line was removed.
Formatting was changed.

...

Code Block

public synchronized <KIn, VIn, KOut, VOut> VIn> StreamsBuilder addGlobalStore(
  final StoreBuilder storeBuilder,
  final String topic,
  final ConsumedConsumed<KIn, VIn> consumed,
  final processor.api.ProcessorSupplier<KIn, VIn, KOutVoid, VOut>Void> stateUpdateSupplier
);

(new method) org.apache.kafka.streams.Topology

...