GlobalStateManager

GlobalStateManager is the contract for custom StateManagers that are checkpointable and…​FIXME

package org.apache.kafka.streams.processor.internals;

interface GlobalStateManager extends StateManager {
  Set<String> initialize();
  void setGlobalProcessorContext(final InternalProcessorContext processorContext);
}
Table 1. GlobalStateManager Contract
Method Description

initialize

Used when…​FIXME

setGlobalProcessorContext

Used when…​FIXME

results matching ""

    No results matching ""