ThreadCache¶

Creating Instance¶

ThreadCache takes the following to be created:

• LogContext
• Maximum Cache Size
• StreamsMetricsImpl

ThreadCache is created when:

• GlobalStreamThread is created
• StandbyTaskCreator is created
• StreamThread utility is used to create a StreamThread (and creates a ActiveTaskCreator)

Maximum Cache Size¶

ThreadCache is given the maximum cache size (in bytes) when created.

The cache size is determined using cache.max.bytes.buffering configuration property when KafkaStreams is created and requested to addStreamThread.

getOrCreateCache¶

NamedCache getOrCreateCache(
  String name)

getOrCreateCache...FIXME

getOrCreateCache is used when:

• ThreadCache is requested to addDirtyEntryFlushListener, put, putIfAbsent, maybeEvict

put¶

void put(
  String namespace,
  Bytes key,
  LRUCacheEntry value)

put...FIXME

put is used when:

• CachingKeyValueStore is requested to putInternal and getInternal
• CachingSessionStore is requested to put
• CachingWindowStore is requested to put

flush¶

void flush(
  String namespace)

flush...FIXME

flush is used when:

• CachingKeyValueStore is requested to flush, flushCache, close
• CachingSessionStore is requested to flush, flushCache, close
• CachingWindowStore is requested to flush, flushCache, close

sizeBytes¶

long sizeBytes()

sizeBytes is the sum of all the sizes of the NamedCaches.

sizeBytes is used when:

• ThreadCache is requested to resize and maybeEvict