如何创建一个Topic？

Kafka 消息系统中的Topic 主要是存储不同类别的消息。在Kafka 中创建Topic 时，在任何一台Broker 节点执行创建命令都可以，这里以在mynode1 节点执行创建命令为例，创建Kafka Topic 的命令如下：

上面命令是在Kafka 消息系统中创建了名称为firsttopic 的消息队列。关于上面命令的详细解释如下。

kafka-topic.sh：执行Kafka Topic 脚本，这个脚本可以创建、修改、删除、查看Kafka集群中的信息。

·create：执行当前操作，创建Topic。

·topic：指定当前创建Topic 的名称。(www.xing528.com)

·partitions：指定当前Topic 的分区数，方便生产者生产消息和消费者并行消费消息。

·replication-factor：指定当前Topic 的分区数据的副本个数，这个个数不能超过当前Kafka 集群所有的Broker 节点。

通过以上命令创建Topic 后，出现“Created topic "firsttopic".”，代表创建Topic 成功。下面使用命令验证Topic 是否创建成功，在任意一台Broker 节点上启动执行查询命令即可查询，这里还是在mynode1 节点上执行查询命令，命令如下：

通过以上查询命令的验证，“firsttopic”创建成功。在××系统中，同样可以创建收集各个网站数据的Topic，按照以上方式创建Topic，为将从××系统采集的数据存入Kafka 中奠定了基础。