GlobalStreamThread

GlobalStreamThread is…​FIXME

GlobalStreamThread is created exclusively when KafkaStreams is created.

Table 1. GlobalStreamThread’s Internal Properties (e.g. Registries, Counters and Flags)
Name Description

cache

ThreadCache

initialize Internal Method

StateConsumer initialize()

initialize…​FIXME

Note
 initialize is used exclusively when GlobalStreamThread is started.

Starting Thread — run Method

void run()
Note
 run is part of Java’s Thread Contract to be executed by a JVM thread.

run…​FIXME

Note
 run is used exclusively when KafkaStreams is started.

Creating GlobalStreamThread Instance

GlobalStreamThread takes the following when created:

GlobalStreamThread initializes the internal registries and counters.

results matching ""

    No results matching ""