首页 理论教育 快速了解:如何查看集群中的Topic

快速了解:如何查看集群中的Topic

时间:2023-07-01 理论教育 版权反馈
【摘要】:搭建好Kafka 集群后,在集群中默认是没有Topic 的,需要创建Topic。下面执行查看Kafka 集群中的Topic 命令,执行命令如下:上述命令可以在Kafka 集群的任何一台Broker 节点中执行,以上命令参数的解释如下:·zookeeper:指定当前Kafka 集群的ZooKeeper 节点,便于寻找Topic 元数据信息。由于刚搭建好Kafka 集群,还没有创建Topic 信息,所以目前查询不到Topic 的详细信息,现在介绍如何使用命令在Kafka 中创建Topic。

快速了解:如何查看集群中的Topic

搭建好Kafka 集群后,在集群中默认是没有Topic 的,需要创建Topic。创建Topic 后,查询后才能看到创建的Topic。查询Topic 时,首先需要启动Kafka 集群,而启动Kafka 集群需要先启动ZooKeeper 集群。

①启动ZooKeeper 集群,命令如下:

②启动Kafka 集群。要启动Kafka 集群,需要在每台Broker 节点上单独启动Kafka。

在mynode1 节点上执行命令,启动Kafka,命令如下:

在mynode2 上单独启动Kafka,执行如下命令:

在mynode3 上单独启动Kafka,执行如下命令:

在mynode1、mynode2、mynode3 节点上启动Kafka 集群的命令执行后,Kafka 进程会占用当前节点的前台终端。为了避免这个问题,在前面项目中提到在mynode1、mynode2、mynode3 每台节点路径/software/kafka_2.11-0.11.0.3/下配置startkafka.sh 脚本。脚本内容如下:(www.xing528.com)

上面脚本的意思是将Kafka 启动后,以后台方式启动,不占用当前节点的终端。将启动产生的日志写入文件kafka.log 中,此后,再涉及启动Kafka 时,就可以启动当前脚本startkafka.sh,这样就避免了Kafka 进程占用节点终端的问题。

下面执行查看Kafka 集群中的Topic 命令,执行命令如下:

上述命令可以在Kafka 集群的任何一台Broker 节点中执行,以上命令参数的解释如下:

·zookeeper:指定当前Kafka 集群的ZooKeeper 节点,便于寻找Topic 元数据信息。

·list:列举当前Kafka 集群中所有的Topic 信息。

由于刚搭建好Kafka 集群,还没有创建Topic 信息,所以目前查询不到Topic 的详细信息,现在介绍如何使用命令在Kafka 中创建Topic。

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

我要反馈