【kafka】常用命令行

2020-01-13 12:07:19 阅读：174 来源： 互联网

标签：zookeeper kafka topic sh master 常用命令 first

启停

（下面操作，都已配置环境变量）

先启动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 -daemon config/server.properties

关闭kafka

$ kafka-server-stop.sh config/server.properties

topic

创建一个topic

topic的分区会被创建在当前主机，每个分区的副本会分配到集群的其他机器；

比如下面例子：

在master上创建了两个分区：first-0、first-1
在slave1上会存放分区之一的一个副本：first-0
在slave2上会存放分区之一的一个副本：first-1

# -create创建
# --zookeeper master:2181；信息写入zookeeper（新版：--bootstrap-server）
# --partitions 2；partition数量
# --replication-factor 2；副本数，根据集群数量来定，不能超过集群数
# --topic first；topic的名字
$ kafka-topics.sh --create --zookeeper master:2181 --partitions 2 --replication-factor 2 --topic first
Created topic "first".

查看topic

# 查看所有topic
$ kafka-topics.sh --list --zookeeper master:2181
first
# 查看某一个topic详细信息
$ kafka-topics.sh --zookeeper master:2181 --describe --topic first
Topic:first PartitionCount:2    ReplicationFactor:2 Configs:
    Topic: first    Partition: 0    Leader: 2   Replicas: 2,1   Isr: 2,1
    Topic: first    Partition: 1    Leader: 0   Replicas: 0,2   Isr: 0,2

查看分区offset

$ kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test
test:0:16
test:1:18

删除topic

并不能真正删除，会被标记为删除

$ kafka-topics.sh --delete --zookeeper master:2181 --topic first
Topic first is marked for deletion.

若想真正删除：

# 启动zookeeper客户端
$ zkCli.sh
# 找到目录
ls /brokers/topics
# 删除
rmr /brokers/topics/first

生产消费

创建producer

$ kafka-console-producer.sh --broker-list master:9092 --topic first
>hello   # 发送消息

创建consumer

连接的是zookeeper

$ kafka-console-consumer.sh --bootstrap-server master:9092 --topic first --from-beginning
hello    # 收到消息

标签：zookeeper,kafka,topic,sh,master,常用命令,first
来源： https://www.cnblogs.com/mussessein/p/12186629.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9