DynamicConfigManager

DynamicConfigManager is…​FIXME

DynamicConfigManager is created exclusively when KafkaServer is requested to start up.

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

adminZkClient

Used when…​FIXME

startup Method

startup

startup…​FIXME

Note
startup is used exclusively when KafkaServer is requested to start up.

Creating DynamicConfigManager Instance

DynamicConfigManager takes the following when created:

DynamicConfigManager initializes the internal registries and counters.

ConfigChangedNotificationHandler Object

ConfigChangedNotificationHandler is a NotificationHandler that processNotification.

Processing Config Change Notifications — processNotification Method

processNotification(jsonBytes: Array[Byte]): Unit
Note
processNotification is part of the NotificationHandler Contract to handle a change notification.

processNotification…​FIXME

processEntityConfigChangeVersion1 Internal Method

processEntityConfigChangeVersion1(jsonBytes: Array[Byte], js: JsonObject): Unit

processEntityConfigChangeVersion1…​FIXME

Note
processEntityConfigChangeVersion1 is used when…​FIXME

processEntityConfigChangeVersion2 Internal Method

processEntityConfigChangeVersion2(jsonBytes: Array[Byte], js: JsonObject): Unit

processEntityConfigChangeVersion2…​FIXME

Note
processEntityConfigChangeVersion2 is used when…​FIXME

results matching ""

    No results matching ""