Skip to content

Latest commit

 

History

History
59 lines (39 loc) · 1.7 KB

kafka-streams-StateDirectory.adoc

File metadata and controls

59 lines (39 loc) · 1.7 KB
Raw

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 any of ERROR, INFO, DEBUG, TRACE logging levels 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=TRACE

clean Method

synchronized void clean()

clean…​FIXME

Note
 clean is used when…​FIXME

cleanRemovedTasks Method

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

cleanRemovedTasks…​FIXME

Note
 cleanRemovedTasks is used when…​FIXME

Creating StateDirectory Instance

StateDirectory takes the following when created:

StateDirectory initializes the internal registries and counters.