kafka使用-admin创建

Kafka AdminClient 提供了以编程方式管理 Kafka 集群（如创建主题）的功能，这比依赖脚本更灵活，便于集成到内部系统。

核心步骤

‌初始化客户端‌：配置并创建AdminClient实例，连接到Kafka集群。

代码示例

以下是一个使用 Java 创建 Kafka 主题的示例。

import org.apache.kafka.clients.admin.Admin;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.CreateTopicsResult;
import org.apache.kafka.clients.admin.NewTopic;import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;public class AdminTopicTest {public static void main(String[] args) {Map<String,Object> configMap = new HashMap<>();configMap.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "hadoop101:9092");// 管理员对象final AdminClient admin = AdminClient.create(configMap);// 构建主题时，需要传递三个参数// 1.主题名称：字母，数字，点，下划线，中横线// 2.主题分区的数量// 3.分区副本的数量String topicName = "test1";int partitionCount = 1;short replicationFactor = 1;NewTopic newTopic = new NewTopic(topicName, partitionCount, replicationFactor);// 创建主题CreateTopicsResult topics = admin.createTopics(Arrays.asList(newTopic));admin.close();}
}