kafka admin 如何创建主题

Kafka Admin客户端是Kafka提供的一个用于管理Kafka集群的工具。要使用Kafka Admin客户端创建主题，你需要遵循以下步骤：

1. 添加Kafka Admin客户端依赖

首先，确保你的项目中包含了Kafka Admin客户端的依赖。如果你使用的是Maven，可以在pom.xml文件中添加以下依赖：

    org.apache.kafka
    kafka-admin-client
    3.0.0

如果你使用的是Gradle，可以在build.gradle文件中添加以下依赖：

implementation 'org.apache.kafka:kafka-admin-client:3.0.0'

请注意，你需要根据你的Kafka版本选择合适的依赖。

2. 创建Kafka Admin客户端实例

接下来，你需要创建一个Kafka Admin客户端实例。你可以使用以下代码创建一个客户端实例：

import org.apache.kafka.clients.admin.*;
import java.util.Collections;
import java.util.Properties;

public class KafkaAdminExample {
    public static void main(String[] args) {
        Properties adminClientProps = new Properties();
        adminClientProps.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        adminClientProps.put(AdminClientConfig.CLIENT_ID_CONFIG, "my-admin-client");

        try (AdminClient adminClient = AdminClient.create(adminClientProps)) {
            // 创建主题的逻辑在这里
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

请确保将BOOTSTRAP_SERVERS_CONFIG设置为你的Kafka集群的地址。

3. 创建主题

要创建一个新主题，你需要使用NewTopic请求。以下是一个创建名为my-new-topic的主题的示例：

import org.apache.kafka.clients.admin.*;
import java.util.Collections;
import java.util.Properties;

public class KafkaAdminExample {
    public static void main(String[] args) {
        // ... 创建AdminClient实例的代码

        NewTopic newTopic = new NewTopic("my-new-topic", 3, (short) 1);
        CreateTopicsResult createTopicsResult = adminClient.createTopics(Collections.singletonList(newTopic));

        createTopicsResult.all().get();
        System.out.println("Topic created successfully");
    }
}

在这个示例中，我们创建了一个名为my-new-topic的主题，具有3个分区和1个副本。all().get()方法会阻塞，直到所有主题创建操作完成。如果创建成功，你将看到输出"Topic created successfully"。

这就是使用Kafka Admin客户端创建主题的方法。请根据你的需求调整代码中的参数。