kafka-streams-internals-ChangeLoggingSessionBytesStore.adoc

ChangeLoggingSessionBytesStore

ChangeLoggingSessionBytesStore is a SessionStore that uses Kafka Bytes (immutable byte arrays) for keys.

ChangeLoggingSessionBytesStore is created exclusively when SessionStoreBuilder is requested to build a MeteredSessionStore (with logging enabled).

ChangeLoggingSessionBytesStore takes a SessionStore when created.

Table 1. ChangeLoggingSessionBytesStore’s Internal Properties (e.g. Registries, Counters and Flags)

Name	Description
changeLogger	StoreChangeLogger Used when…​FIXME
innerStateSerde	StateSerdes Used when…​FIXME

Initialize State Store — init Method

void init(final ProcessorContext context, final StateStore root)

Note	init is part of…​FIXME

init…​FIXME

Storing Aggregated Value for Session Key — put Method

void put(final Windowed<Bytes> sessionKey, final byte[] aggregate)

Note	put is part of SessionStore Contract to store an aggregated value for a session key.

put requests the SessionStore to store the aggregated value for the given session key.

In the end, put…​FIXME