kafka-streams-GlobalStateManagerImpl.adoc

GlobalStateManagerImpl

GlobalStateManagerImpl is a custom GlobalStateManager that…​FIXME

GlobalStateManagerImpl is created when…​FIXME

initialize Method

Set<String> initialize()

Note	initialize is part of GlobalStateManager Contract to…​FIXME.

initialize…​FIXME

checkpoint Method

void checkpoint(final Map<TopicPartition, Long> offsets)

Note	checkpoint is part of Checkpointable Contract to…​FIXME.

checkpoint…​FIXME

Creating GlobalStateManagerImpl Instance

GlobalStateManagerImpl takes the following when created:

• LogContext

• ProcessorTopology

• (Global) Kafka Consumer (of keys and values as array of bytes)

• StateDirectory

• StateRestoreListener

• StreamsConfig

GlobalStateManagerImpl initializes the internal registries and counters.