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.

alterConfigs Method

AlterConfigsResult alterConfigs(
  Map<ConfigResource, Config> configs,
  final AlterConfigsOptions options)
// Private API
Map<ConfigResource, KafkaFutureImpl<Void>> alterConfigs(
  Map<ConfigResource, Config> configs,
  final AlterConfigsOptions options,
  Collection<ConfigResource> resources,
  NodeProvider nodeProvider)
Note
alterConfigs is part of the AdminClient Contract to…​FIXME.

alterConfigs…​FIXME

describeCluster Method

DescribeClusterResult describeCluster(DescribeClusterOptions options)
Note
describeCluster is part of the AdminClient Contract to…​FIXME.

describeCluster…​FIXME

deleteRecords Method

DeleteRecordsResult deleteRecords(
  final Map<TopicPartition, RecordsToDelete> recordsToDelete,
  final DeleteRecordsOptions options)
Note
deleteRecords is part of the AdminClient Contract to…​FIXME.

deleteRecords…​FIXME

listConsumerGroups Method

ListConsumerGroupsResult listConsumerGroups(ListConsumerGroupsOptions options)
Note
listConsumerGroups is part of the AdminClient Contract to…​FIXME.

listConsumerGroups…​FIXME

listTopics Method

ListTopicsResult listTopics(final ListTopicsOptions options)
Note
listTopics is part of the AdminClient Contract to…​FIXME.

listTopics…​FIXME

describeConsumerGroups Method

DescribeConsumerGroupsResult describeConsumerGroups(
  final Collection<String> groupIds,
  final DescribeConsumerGroupsOptions options)
Note
describeConsumerGroups is part of the AdminClient Contract to…​FIXME.

describeConsumerGroups…​FIXME

listConsumerGroupOffsets Method

ListConsumerGroupOffsetsResult listConsumerGroupOffsets(
  final String groupId,
  final ListConsumerGroupOffsetsOptions options)
Note
listConsumerGroupOffsets is part of the AdminClient Contract to…​FIXME.

listConsumerGroupOffsets…​FIXME

deleteConsumerGroups Method

DeleteConsumerGroupsResult deleteConsumerGroups(
  Collection<String> groupIds,
  DeleteConsumerGroupsOptions options)
Note
deleteConsumerGroups is part of the AdminClient Contract to…​FIXME.

deleteConsumerGroups…​FIXME

createTopics Method

CreateTopicsResult createTopics(
  final Collection<NewTopic> newTopics,
  final CreateTopicsOptions options)
Note
createTopics is part of the AdminClient Contract to…​FIXME.

createTopics…​FIXME

deleteTopics Method

DeleteTopicsResult deleteTopics(
  Collection<String> topicNames,
  DeleteTopicsOptions options)
Note
deleteTopics is part of the AdminClient Contract to…​FIXME.

deleteTopics…​FIXME

createPartitions Method

CreatePartitionsResult createPartitions(
  Map<String, NewPartitions> newPartitions,
  final CreatePartitionsOptions options)
Note
createPartitions is part of the AdminClient Contract to…​FIXME.

createPartitions…​FIXME

results matching ""

    No results matching ""