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 發佈！