Kafka 创建主题

Kafka 是一个分布式流处理平台，主要用于处理实时数据流。在 Kafka 中，主题（Topic）是数据的类别，是Kafka中数据交换的最小单元。下面将介绍如何在Kafka中创建主题。

步骤

1. 打开终端或命令行窗口，进入 Kafka 安装目录下的 bin 目录：

   cd /path/to/kafka/bin
   

2. 执行以下命令来创建一个名为 my-topic 的主题：

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

   • --create：表示创建主题。
   • --zookeeper：表示指定 ZooKeeper 的地址和端口。
   • --replication-factor：表示设置主题的数据副本数。
   • --partitions：表示设置主题的分区数量。
   • --topic：表示指定主题的名称。

3. 执行以下命令来查看所有主题：

   ./kafka-topics.sh --list --zookeeper localhost:2181
   

   • --list：表示列出所有主题。

4. 执行以下命令来查看 my-topic 主题的详细信息：

   ./kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-topic
   

   • --describe：表示查看主题的详细信息。

结论

以上是创建Kafka主题的简单步骤。通过运用这个步骤，我们可以轻松地在Kafka中创建一个主题来实现真正的流处理。