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.


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

Add the following line to

results matching ""

    No results matching ""