kafka常用的命令

fox_soyoung 发布于2019-07-16 14:35 / 1285人阅读

摘要：启动查看是否启动关闭查看的状态启动查看是否启动关闭创建查看所有查看某个具体信息删除可直接删除的前提命令无法删除，被标记为删除时候，用下面命令删除生产消息消费消息

1、启动zookeeper

# ./zkServer.sh start

2、查看zookeeper是否启动

# ps -ef |grep java

3、关闭zookeeper

# ./zkServer.sh stop

4、查看zookeeper的状态

# ./zkServer.sh status

5、启动kafka

# ./kafka-server-start.sh -daemon ../config/server.properties &

6、查看kafka是否启动

# ps -ef |grep kafka

7、关闭kafka

# ./kafka-server-stop.sh

8、创建topic

# ./kafka-topics.sh --create --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 --replication-factor 3 --partitions 1 --topic szy

9、查看所有topic

# ./kafka-topics.sh --list --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181

10、查看某个topic具体信息

# ./kafka-topics.sh --describe --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 --topic szy

11、删除topic (可直接删除的前提：delete.topic.enable=true)

# ./kafka-topics.sh --delete --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 --topic test 
命令无法删除，topic被标记为删除时候，用下面命令删除
# cd /usr/local/zookeeper-node3/bin/
# ./zkCli.sh
ls /brokers/topics
rmr /brokers/topics/【topic name】
quit

12、生产消息

# ./kafka-console-producer.sh --broker-list 172.16.218.201:19092,172.16.218.202:19092,172.16.218.203:19092 --topic szy

13、消费消息

# ./kafka-console-consumer.sh --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181  --topic szy --from-beginning

专线服务超融合服务器常用的linux命令 linux常用的命令 linux的常用命令 hbase的常用命令

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/33828.html

大数据入门指南（GitHub开源项目）

摘要：项目地址前言大数据技术栈思维导图大数据常用软件安装指南一分布式文件存储系统分布式计算框架集群资源管理器单机伪集群环境搭建集群环境搭建常用命令的使用基于搭建高可用集群二简介及核心概念环境下的安装部署和命令行的基本使用常用操作分区表和分桶表视图项目GitHub地址：https://github.com/heibaiying... 前言大数据技术栈思维导图大数据常用软件安装指...

guyan0319 2019-08-19 11:46 评论0 收藏0
PHP下kafka的常用脚本实践

摘要：阅读本教程前最好先尝试阅读下的实践自带命令实践尝试实践的知识创建话题生产消息消费消息话题信息获取消费组获取消费组的自带的命令安装目录的目录下代表我们会使用的脚本阅读本教程前最好先尝试阅读：PHP下kafka的实践自带命令实践尝试实践的kafka知识：创建话题生产消息消费消息话题信息获取消费组获取消费组的offset 自带的命令 # kafka安装目录的bin目录下...

Airmusic 2019-07-16 14:46 评论0 收藏0
PHP下kafka的常用脚本实践

摘要：阅读本教程前最好先尝试阅读下的实践自带命令实践尝试实践的知识创建话题生产消息消费消息话题信息获取消费组获取消费组的自带的命令安装目录的目录下代表我们会使用的脚本阅读本教程前最好先尝试阅读：PHP下kafka的实践自带命令实践尝试实践的kafka知识：创建话题生产消息消费消息话题信息获取消费组获取消费组的offset 自带的命令 # kafka安装目录的bin目录下...

caiyongji 2019-07-01 10:33 评论0 收藏0
kafka常用命令

./kafka-server-stop.sh 直接执行，无需加任何参数，当前机器中的所有broker都会被停止。

DrizzleX 2019-07-16 14:52 评论0 收藏0
Kafka集群部署指南

摘要：另外，也是目前性能最好的消息中间件。架构在集群中，一个节点就是一个，消息由来承载，可以存储在个或多个中。发布消息的应用为消费消息的应用为，多个可以促成共同消费一个中的消息。一、前言 1、Kafka简介 Kafka是一个开源的分布式消息引擎/消息中间件，同时Kafka也是一个流处理平台。Kakfa支持以发布/订阅的方式在应用间传递消息，同时并基于消息功能添加了Kafka Connect...

qc1iu 2019-07-16 14:52 评论0 收藏0