AdminManager

AdminManager is…​FIXME

AdminManager is created exclusively when KafkaServer is started.

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

adminZkClient

alterConfigPolicy

createTopicPolicy

topicPurgatory

AdminManager uses [Admin Manager on Broker [brokerId]] as the logging prefix (aka logIdent).

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 is requested to handle 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

createPartitions Method

createPartitions(
  timeout: Int,
  newPartitions: Map[String, PartitionDetails],
  validateOnly: Boolean,
  listenerName: ListenerName,
  callback: Map[String, ApiError] => Unit): Unit

createPartitions…​FIXME

Note
createPartitions is used when…​FIXME

results matching ""

    No results matching ""