2.2 KAFKA 命令行操作
1) 查看当前服务器中的所有 topic
[[email protected] kafka]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 --list
2) 创建 topic
- [[email protected] kafka]$ bin/kafka-topics.sh --zookeeper hadoop102:2181
- --create --replication-factor 3 --partitions 1 --topic first
选项说明:
--topic 定义 topic 名
--replication-factor 定义副本数
--partitions 定义分区数
3) 删除 topic
- [[email protected] kafka]$ bin/kafka-topics.sh --zookeeper hadoop102:2181
- --delete --topic first
需要 server.properties 中设置 delete.topic.enable=true 否则只是标记删除.
4) 生产消息
- [[email protected] kafka]$ bin/kafka-console-producer.sh --broker-list hadoop102:9092 --topic first
- >hello world
- >aa
5) 消费消息
[[email protected] kafka]$ bin/kafka-console-consumer.sh --Bootstrap-server hadoop102:9092 --from-beginning --topic first
--from-beginning: 会把主题中以往所有的数据都读取出来.
6) 查看某个 Topic 的详情
[[email protected] kafka]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 --describe --topic first
7) 修改分区数
- [[email protected] kafka]$bin/kafka-topics.sh --zookeeper .hadoop102:2181 --alter --topic first --partitions 6
- 8) bin/kafka-consumer-groups.sh -Bootstrap-server Hadoop102:9092 -list
来源: http://www.bubuko.com/infodetail-3304220.html