博客

1、Linux相关命令

kafka是二进制安装



路径: /data/soft/kafka/kafka_2.12-2.2.2/

topic相关

-- 创建topic
/data/soft/kafka/kafka_2.12-2.2.2/bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic 主题（即topic） --replication-factor 1 --partitions 2

-- 接收某topic下的数据
/data/soft/kafka/kafka_2.12-2.2.2/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic 主题（即topic）  --from-beginning

-- 查看某topic的属性
/data/soft/kafka/kafka_2.12-2.2.2/bin/kafka-topics.sh --zookeeper localhost:2181 --topic 主题（即topic） --describe

-- 查看topic的列表
/data/soft/kafka/kafka_2.12-2.2.2/bin/kafka-topics.sh --zookeeper localhost:2181 --list

-- 向topic发送消息
/data/soft/kafka/kafka_2.12-2.2.2/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic 主题（即topic）

--删除topic
 cd /data/soft/kafka/kafka_2.12-2.2.2/bin/ && bash kafka-topics.sh --delete --zookeeper localhost:2181 --topic 主题

--查看topic是否有数据   若没有任何返回或没有响应，则该topic中没有数据内容；否则有
/data/soft/kafka/kafka_2.12-2.2.2/bin/kafka-console-consumer.sh --bootstrap-server 10.0.4.10:9092 --topic mtalog_GameCreateRoleEvent --from-beginning

consumer相关

-- 查看消费者列表
/data/soft/kafka/kafka_2.12-2.2.2/bin/kafka-consumer-groups.sh --bootstrap-server 10.209.0.6:9092 --list

-- 查看某消费者下的数据是否消费完毕
/data/soft/kafka/kafka_2.12-2.2.2/bin/kafka-consumer-groups.sh --describe  --bootstrap-server 10.209.0.6:9092 --group 消费者名称（可以查看内网地址）

TOPIC              ---topic名字
PARTITION          ---分区id
CURRENT-OFFSET     ---当前已消费的条数
LOG-END-OFFSET     ---总条数
LAG                ---未消费的条数
CONSUMER-ID        ---消费id
HOST               ---主机ip
CLIENT-ID          ---客户端id

2、window相关命令

--创建topic：
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

--查看topic：
kafka-topics.bat --describe --zookeeper localhost:2181 --topic test

--创建生产者：
kafka-console-producer.bat --broker-list localhost:9092 --topic test

--消费者：
 kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test

到此文章结束，谢谢您的观看。如若文章有错误理解，欢迎批评指正，同时非常期待你的评论、点赞和收藏。 😊