org.apache.kafka.streams.state

Interface SessionBytesStoreSupplier

All Superinterfaces:

StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>

public interface SessionBytesStoreSupplier
extends StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>

A store supplier that can be used to create one or more SessionStore> instances of type <Byte, byte[]>.

Method Summary

Modifier and Type	Method and Description
long	segmentIntervalMs() The size of a segment, in milliseconds.

Methods inherited from interface org.apache.kafka.streams.state.StoreSupplier

get, metricsScope, name

Method Detail

segmentIntervalMs

long segmentIntervalMs()

The size of a segment, in milliseconds. Used when caching is enabled to segment the cache and reduce the amount of data that needs to be scanned when performing range queries.

Returns:

segmentInterval in milliseconds