AdminManager

AdminManager is…​FIXME

AdminManager is created exclusively when KafkaServer is started.

AdminManager.png
Figure 1. AdminManager

logIdent is [Admin Manager on Broker [brokerId]].

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

alterConfigPolicy

createTopicPolicy

topicPurgatory

Tip

Enable INFO, DEBUG, TRACE logging levels for kafka.server.AdminManager logger to see what happens inside.

Add the following line to config/log4j.properties:

log4j.logger.kafka.server.AdminManager=TRACE

Refer to Logging.

Creating Topics — createTopics Method

createTopics(
  timeout: Int,
  validateOnly: Boolean,
  createInfo: Map[String, CreateTopicsRequest.TopicDetails],
  responseCallback: (Map[String, ApiError]) => Unit): Unit

createTopics…​FIXME

Note
createTopics is used exclusively when KafkaApis handles a CREATE_TOPICS request.

Creating AdminManager Instance

AdminManager takes the following when created:

AdminManager initializes the internal registries and counters.

describeConfigs Method

describeConfigs(
  resourceToConfigNames: Map[ConfigResource, Option[Set[String]]],
  includeSynonyms: Boolean): Map[ConfigResource, DescribeConfigsResponse.Config]

describeConfigs…​FIXME

Note
describeConfigs is used when…​FIXME

alterConfigs Method

alterConfigs(
  configs: Map[ConfigResource, AlterConfigsRequest.Config],
  validateOnly: Boolean): Map[ConfigResource, ApiError]

alterConfigs…​FIXME

Note
alterConfigs is used exclusively when KafkaApis is requested to handleAlterConfigsRequest.

configSynonyms Internal Method

configSynonyms(
  name: String,
  synonyms: List[String],
  isSensitive: Boolean): List[DescribeConfigsResponse.ConfigSynonym]

configSynonyms…​FIXME

Note
configSynonyms is used when…​FIXME

results matching ""

    No results matching ""