kafka-streams-internals-SessionStoreBuilder.adoc

SessionStoreBuilder

SessionStoreBuilder is an AbstractStoreBuilder that builds a MeteredSessionStore (possibly with caching and logging).

SessionStoreBuilder is created exclusively when Stores is requested to create one (with Time.SYSTEM time).

Creating SessionStoreBuilder Instance

SessionStoreBuilder takes the following when created:

• SessionBytesStoreSupplier

• Serde for keys

• Serde for values

• Time

Building MeteredSessionStore (with Optional Caching and Logging) — build Method

SessionStore<K, V> build()

Note	build is part of StoreBuilder Contract to build a StateStore.

build…​FIXME

maybeWrapCaching Internal Method

SessionStore<Bytes, byte[]> maybeWrapCaching(final SessionStore<Bytes, byte[]> inner)

maybeWrapCaching…​FIXME

Note	maybeWrapCaching is used when…​FIXME

maybeWrapLogging Internal Method

SessionStore<Bytes, byte[]> maybeWrapLogging(final SessionStore<Bytes, byte[]> inner)

maybeWrapLogging…​FIXME

Note	maybeWrapLogging is used when…​FIXME