【摘要】:Kafka 消息系统中的Topic 主要是存储不同类别的消息。kafka-topic.sh:执行Kafka Topic 脚本,这个脚本可以创建、修改、删除、查看Kafka集群中的信息。·partitions:指定当前Topic 的分区数,方便生产者生产消息和消费者并行消费消息。通过以上命令创建Topic 后,出现“Created topic "firsttopic".”,代表创建Topic 成功。在××系统中,同样可以创建收集各个网站数据的Topic,按照以上方式创建Topic,为将从××系统采集的数据存入Kafka 中奠定了基础。
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 中奠定了基础。
免责声明:以上内容源自网络,版权归原作者所有,如有侵犯您的原创版权请告知,我们将尽快删除相关内容。