GlobalStateMaintainer

GlobalStateMaintainer is the contract for managing global state stores.

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

interface GlobalStateMaintainer {
  void close() throws IOException;
  void flushState();
  Map<TopicPartition, Long> initialize();
  void update(ConsumerRecord<byte[], byte[]> record);
}
Table 1. GlobalStateMaintainer Contract
Method Description

close

 
void close() throws IOException

Used when…​FIXME

flushState

Used when…​FIXME

initialize

Used when…​FIXME

update

Used when…​FIXME
Note
 GlobalStateUpdateTask is the one and only GlobalStateMaintainer.

results matching ""

    No results matching ""