采纳
Admin API 用于管理和检查topic、broker、acls和其他Kafka对象。
要使用Admin API,请添加以下Maven依赖关系。
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.7.0</version> </dependency>
参见使用Java管理kafka集群.