KafkaAdminClient

KafkaAdminClient is a AdminClient that…​FIXME

KafkaAdminClient is created when…​FIXME

describeTopics Method

DescribeTopicsResult describeTopics(final Collection<String> topicNames, DescribeTopicsOptions options)

describeTopics…​FIXME

Note
describeTopics is used when…​FIXME

alterReplicaLogDirs Method

AlterReplicaLogDirsResult alterReplicaLogDirs(
  Map<TopicPartitionReplica, String> replicaAssignment,
  final AlterReplicaLogDirsOptions options)

alterReplicaLogDirs…​FIXME

Note
alterReplicaLogDirs is used when…​FIXME

Creating KafkaAdminClient Instance

KafkaAdminClient takes the following when created:

  • AdminClientConfig

  • client ID

  • sanitized client ID

  • Time

  • Metadata

  • Metrics

  • KafkaClient

  • TimeoutProcessorFactory

  • LogContext

KafkaAdminClient initializes the internal registries and counters.

results matching ""

    No results matching ""