Skip to content

ThreadCache

Creating Instance

ThreadCache takes the following to be created:

ThreadCache is created when:

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:

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:

Back to top