kafka的常用命令

在此目录下运行命令
/opt/kafka_2.12-2.2.0/

启动内置的zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties

启动kafka服务
bin/kafka-server-start.sh config/server.properties

创建topic话题
bin/kafka-topics.sh --create --topic news（话题名） --bootstrap-server 192.168.79.137（Linux ip地址）:9092 -partitions（分区） 3 -replication-factor 1

查看所有topic话题
bin/kafka-topics.sh --list --bootstrap-server 192.168.79.137:9092

查看指定话题的详情
bin/kafka-topics.sh --bootstrap-server 192.168.79.137:9092 --describe --topic news

创建生产者
bin/kafka-console-producer.sh --broker-list 192.168.237.129:9092 --topic news

创建消费者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.237.129:9092 --topic news

使用外置的zookeeper，内置和外置只需要开一个即可
以下命令是在此目录下运行
/opt/zookeeper-3.4.14

启动zookeeper
bin/zkServer.sh start

查看zookeeper状态
bin/zkServer.sh status

停止zookeeper
bin/zkServer.sh stop

原文地址：https://www.cnblogs.com/haogege1204/p/12247849.html

时间： 2024-10-10 18:55:24

kafka的常用命令的相关文章

kafka zk常用命令

1 创建topic: kafka-topics.sh --create --zookeeper 3.3.3.3:2181 --replication-factor 1 --partitions 3 --topic test_one replication-factor 副本的个数 (因为创建的副本都是存储在其他broker的,所以这里配置的个数不能大于集群中的broker个数) partitions 分区个数执行后的结构: drwxr-xr-x 2 root root 4096 8月 11

kafka深度研究之路(5)-kafka新版常用命令汇总

小结:1/列出topic的命令为:kafka-topics.sh --zookeeper 10.211.55.11:2181,10.211.55.12:2181,10.211.55.13:2181/kafkagroup --list2/删除topic的命令为:kafka-topics.sh --delete --zookeeper 10.211.55.11:2181,10.211.55.12:2181,10.211.55.13:2181/kafkagroup --topic topic-maji

【Kafka】常用命令

创建Topic kafka-topics.sh --create --bootstrap-server localhost:9092 --topic abtest --partitions 2 --replication-factor 1 查看Topic都有哪些 kafka-topics.sh --list --zookeeper localhost:2181 生产者,将文件中的数据写入Kafka生产者 kafka-console-producer.sh --broker-list localh

Kafka基础——常用命令行操作

目录集群启动集群启动启动zookeeper集群 cd /usr/app/zookeeper/bin ./zkServer.sh start 依次启动. 启动kafka集群 cd /usr/app/kafka bin/kafka-server-satrt.sh -daemon config/server.properties(隐藏后台启动) bin/kafka-server-satrt.sh config/server.properties(带后台启动,无法做其他操作) 依次启动关闭集群

【kafka】常用命令行

启停 (下面操作,都已配置环境变量) 先启动zookeeper $ zkServer.sh status # 查看zookeeper状态 JMX enabled by default Using config: /home/whr/workbench/zookeeper/bin/../conf/zoo.cfg Mode: follower 启动kafka # 后台启动,需要配置参数 # 不加-daemon,会是一个阻塞进程,可以方便看日志 $ kafka-server-start.sh -dae

kafka安装及常用命令

kafka是一个开源的分布式消息队列他提供可靠的集群容错机制,并保证故障切换时的数据完整性. 无论从性能.可靠性.易用性都强过ActiveMQ(client的API感觉还是不如ActiveMQ好用,文档也没有更新到最新版) 下面简单记录一下安装步骤和常用命令. 1.安装 http://kafka.apache.org/documentation.html 下载压缩包并解压可以解压到 /usr/local/kafka 2.配置 vim conf/server.properties #设置bro

Kafka系列(二)特性和常用命令

Kafka中Replicas复制备份机制 kafka将每个partition数据复制到多个server上,任何一个partition有一个leader和多个follower(可以没有),备份的个数可以通过broker配置文件来设定(replication-factor的参数配置指定).leader处理所有的read-write请求,follower需要和leader保持同步.Follower和consumer一样,消费消息并保存在本地日志中,leader负责跟踪所有的follower状态,如果f

flume、kafka、storm常用命令

出自:http://my.oschina.net/jinp/blog/350293 一些常用命令: storm相关: storm nimbus >/dev/null 2>&1 & storm supervisor >/dev/null 2>&1 & storm ui >/dev/null 2>&1 & 关闭storm ps -ef|grep apache-storm-0.9.2-incubating|grep -v gre

大数据入门第十七天——storm上游数据源之kafka详解（二）常用命令

一.kafka常用命令 1.创建topic bin/kafka-topics.sh --create --topic topic_1 --partitions 4 --replication-factor 2 --zookeeper mini1:2181 // 如果配置了PATH可以省略相关命令路径,相关命令参数暂不深入,字面意思也可以大概推断.后续给出完整参数参考. 2.查看所有topic bin/kafka-topics.sh --list --zookeeper mini1:2181 3.