linux下kafka创建topic的几种方式

在Linux下，Kafka创建topic的几种方式如下：

1. 使用kafka-topics.sh脚本创建topic

在Linux系统上的Kafka安装目录下，有一个bin目录，其中有一个名为kafka-topics.sh的脚本文件，可以使用该脚本创建Kafka的topic。

例如，要创建一个名为test的topic，可以使用以下命令：

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

其中，--create选项表示创建topic，--zookeeper指定Zookeeper的地址，--replication-factor指定副本因子，--partitions指定分区数，--topic指定topic名称。

2. 使用kafkacat工具创建topic

kafkacat是一个Kafka命令行工具，它可以用来创建Kafka的topic。

例如，要创建一个名为test的topic，可以使用以下命令：

kafkacat -b localhost:9092 -t test -P -K:

其中，-b指定Kafka的地址，-t指定topic名称，-P表示生产者模式，-K指定key和value之间的分割符。

3. 使用Java API创建topic

除了使用命令行工具外，还可以使用Java API来创建Kafka的topic。

例如，下面的Java代码可以创建一个名为test的topic：

import kafka.admin.AdminUtils;
import kafka.utils.ZKStringSerializer$;
import org.I0Itec.zkclient.ZkClient;

import java.util.Properties;

public class CreateTopic {
    public static void main(String[] args) {
        String zkConnect = "localhost:2181";
        int sessionTimeoutMs = 10000;
        int connectionTimeoutMs = 10000;
        ZkClient zkClient = new ZkClient(zkConnect, sessionTimeoutMs, connectionTimeoutMs, ZKStringSerializer$.MODULE$);

        String topicName = "test";
        int numPartitions = 1;
        int replicationFactor = 1;
        Properties topicConfig = new Properties();

        AdminUtils.createTopic(zkClient, topicName, numPartitions, replicationFactor, topicConfig);
        zkClient.close();
    }
}

该代码使用了Kafka的AdminUtils类来创建topic，首先创建一个ZkClient对象，然后使用AdminUtils.createTopic方法创建topic。其中，zkConnect指定Zookeeper的地址，numPartitions指定分区数，replicationFactor指定副本因子，topicConfig指定topic的属性。