首页 理论教育 如何创建一个Topic?

如何创建一个Topic?

时间:2023-07-01 理论教育 版权反馈
【摘要】:Kafka 消息系统中的Topic 主要是存储不同类别的消息。kafka-topic.sh:执行Kafka Topic 脚本,这个脚本可以创建、修改、删除、查看Kafka集群中的信息。·partitions:指定当前Topic 的分区数,方便生产者生产消息和消费者并行消费消息。通过以上命令创建Topic 后,出现“Created topic "firsttopic".”,代表创建Topic 成功。在××系统中,同样可以创建收集各个网站数据的Topic,按照以上方式创建Topic,为将从××系统采集的数据存入Kafka 中奠定了基础。

如何创建一个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 中奠定了基础。

免责声明:以上内容源自网络,版权归原作者所有,如有侵犯您的原创版权请告知,我们将尽快删除相关内容。

我要反馈