Skip to content

Latest commit

 

History

History
27 lines (19 loc) · 1.25 KB

kafka-streams-internals-AssignedStandbyTasks.adoc

File metadata and controls

27 lines (19 loc) · 1.25 KB

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
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