KafkaAdminClient-概述

在新版的 Kafka 中的 ZKUtils、AdminUtils 方法都已经过时了，目前 Kafka 提供了一个新的 API 工具 AdminClient。

官网对于 AdminClient 的介绍:

The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects.

Maven 引入

<dependency>
 <groupid>org.apache.kafka/<groupid>
 <artifactid>kafka-clients/<artifactid>
 <version>2.3.0/<version>
/<dependency>

JavaDoc 地址

http://kafka.apachecn.org/10/javadoc/index.html?org/apache/kafka/clients/admin/AdminClient.html

参数配置

参考： http://kafka.apachecn.org/documentation.html#adminclientconfigs

实例创建

Properties props = new Properties();
props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, “localhost:9092”);
AdminClient adminClient = AdminClient.create(props);

注：必须参数就只有一个 bootstrap.servers ，其他相关参数配置见上面的参数配置参考

主要功能

1. 创建Topic：createTopics(Collection newTopics)
2. 删除Topic：deleteTopics(Collection topics)
3. 显示所有Topic：listTopics()
4. 查询Topic：describeTopics(Collection topicNames)
5. 查询集群信息：describeCluster()
6. 查询ACL信息：describeAcls(AclBindingFilter filter)
7. 创建ACL信息：createAcls(Collection acls)
8. 删除ACL信息：deleteAcls(Collection filters)
9. 查询配置信息：describeConfigs(Collection resources)
10. 修改配置信息：alterConfigs(Map configs)
11. 修改副本的日志目录：alterReplicaLogDirs(Map replicaAssignment)
12. 查询节点的日志目录信息：describeLogDirs(Collection brokers)
13. 查询副本的日志目录信息：describeReplicaLogDirs(Collection replicas)
14. 增加分区：createPartitions(Map newPartitions)

本文由博客一文多发平台 https://openwrite.cn?from=article_bottom 发布！