StateDirectory

StateDirectory is…​FIXME

StateDirectory is created when KafkaStreams is created.

StateDirectory uses state.dir and application.id configuration properties for the location of the state store.

Note
 state.dir configuration property defaults to /tmp/kafka-streams.
Tip

Enable ALL logging level for org.apache.kafka.streams.processor.internals.StateDirectory logger to see what happens inside.

Add the following line to log4j.properties:

log4j.logger.org.apache.kafka.streams.processor.internals.StateDirectory=ALL

Refer to Application Logging Using log4j.

clean Method

synchronized void clean()

clean…​FIXME

Note
 clean is used when…​FIXME

cleanRemovedTasks Method

void cleanRemovedTasks(final long cleanupDelayMs) (1)

// private
private void cleanRemovedTasks(
  final long cleanupDelayMs,
  final boolean manualUserCall) throws Exception

  1. Turns the manualUserCall flag off

cleanRemovedTasks…​FIXME

Note
 cleanRemovedTasks is used when…​FIXME

Creating StateDirectory Instance

StateDirectory takes the following when created:

StateDirectory initializes the internal registries and counters.

listTaskDirectories Method

File[] listTaskDirectories()

listTaskDirectories…​FIXME

Note
 listTaskDirectories is used when…​FIXME

Locking State Directory For Task — lock Method

boolean lock(TaskId taskId)

lock…​FIXME

Note
 lock is used when…​FIXME

results matching ""

    No results matching ""