ZkAdminManager¶

incrementalAlterConfigs¶

incrementalAlterConfigs(
  configs: Map[ConfigResource,
  Seq[AlterConfigOp]],
  validateOnly: Boolean): Map[ConfigResource, ApiError]

incrementalAlterConfigs...FIXME

incrementalAlterConfigs is used when:

KafkaApis is requested to processIncrementalAlterConfigsRequest

alterConfigs¶

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

alterConfigs...FIXME

alterConfigs is used when:

KafkaApis is requested to processLegacyAlterConfigsRequest

alterTopicConfigs¶

alterTopicConfigs(
  resource: ConfigResource,
  validateOnly: Boolean,
  configProps: Properties,
  configEntriesMap: Map[String, String]): (ConfigResource, ApiError)

alterTopicConfigs...FIXME

alterTopicConfigs is used when:

ZkAdminManager is requested to alterConfigs (of a topic), incrementalAlterConfigs (of a topic)

Creating Topics¶

createTopics(
  timeout: Int,
  validateOnly: Boolean,
  toCreate: Map[String, CreatableTopic],
  includeConfigsAndMetadata: Map[String, CreatableTopicResult],
  controllerMutationQuota: ControllerMutationQuota,
  responseCallback: Map[String, ApiError] => Unit): Unit

createTopics...FIXME

createTopics is used when:

DefaultAutoTopicCreationManager is requested to createTopicsInZk
KafkaApis is requested to handleCreateTopicsRequest