AssignedStandbyTasks — AssignedTasks For StandbyTasks

AssignedStandbyTasks is a concrete AssignedTasks for StandbyTasks that is created exclusively for the TaskManager for a StreamThread (when KafkaStreams is created).

kafka streams AssignedStandbyTasks.png
Figure 1. AssignedStandbyTasks, TaskManager and StreamThread

AssignedStandbyTasks takes a LogContext when created.

AssignedStandbyTasks uses standby task for taskTypeName.

Tip

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

Add the following line to log4j.properties:

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

Refer to Application Logging Using log4j.

results matching ""

    No results matching ""