ReferenceContainer¶

ReferenceContainer is used to hold all of the following instances:

• Main Kafka Consumer<byte[], byte[]> (Apache Kafka)
• Admin Client (Apache Kafka)
• TaskManager
• StreamsMetadataState
• Assignment Error Code
• Next Scheduled Rebalance Time
• Time

Creating Instance¶

ReferenceContainer takes no arguments to be created.

ReferenceContainer is created when:

• StreamThread utility is used to create a StreamThread