Kafka 常用命令

发表于 分类于

Kafka 的常用命令整理

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
#创建主题
kafka-topics --create --topic dwd_xxx_dwd_trd_order_received --partitions 2 --replication-factor 2 --zookeeper 10.0.15.130:2181,10.0.15.131:2181,10.0.15.132:2181/kafka

#查看主题列表
kafka-topics --list --zookeeper 10.0.15.130:2181,10.0.15.131:2181,10.0.15.132:2181/kafka

#控制台发送消息
kafka-console-producer --topic dwd_xxx_dwd_trd_order_received --broker-list 10.0.15.130:9092

#控制台消费主题
kafka-console-consumer --topic dwd_xxx_dwd_trd_order_received --bootstrap-server 10.0.15.130:9092

#控制台消费主题（从头开始）
kafka-console-consumer --from-beginning --topic dwd_xxx_dwd_trd_order_received --bootstrap-server 10.0.15.130:9092

#控制台消费主题（read_committed 的数据）
kafka-console-consumer --topic flink_checkpoint_sink_test --bootstrap-server 10.0.15.130:9092 --isolation-level read_committed --from-beginning

#查看主题详情
kafka-topics --describe --topic dwd_xxx_dwd_trd_order_received --bootstrap-server 10.0.15.130:9092

#删除主题
kafka-topics --delete --topic dwd_xxx_dwd_trd_order_received --zookeeper 10.0.15.130:2181,10.0.15.131:2181,10.0.15.132:2181/kafka

#查询所有 Group
kafka-consumer-groups --bootstrap-server 10.0.15.130:9092 --list

#查询某 Group Offset 信息
kafka-consumer-groups --bootstrap-server 10.0.15.130:9092 --group test01 --describe

#重置某 Group Offset
kafka-consumer-groups --bootstrap-server 10.0.15.130:9092 --group test01 --topic ck_test:0 --reset-offsets --to-offset 5 --execute