首页 | 新闻 | 新品 | 文库 | 方案 | 视频 | 下载 | 商城 | 开发板 | 数据中心 | 座谈新版 | 培训 | 工具 | 博客 | 论坛 | 百科 | GEC | 活动 | 主题月 | 电子展
返回列表 回复 发帖

Kafka命令清单

Kafka命令清单

一、队列常用命令
#创建topics$ ./kafka-topics.sh --create --zookeeper chenx02:2181 --replication-factor 1 --partitions 1 --topic test

#查看队列列表
$ ./kafka-topics.sh --list --zookeeper chenx02:2181

#查看队列明细
$ ./kafka-topics.sh --describe --zookeeper chenx02:2181 --topic test

#修改(test)队列参数
$ ./kafka-topics.sh --zookeeper chenx02:2181 --partition 3 --topic test --alter

#创建多副本的队列
$ ./kafka-topics.sh --create --zookeeper chenx02:2181 --replication-factor 3 --partitions 4 --topic test_kafka

#删除kafka的队列[注意需要重启kafka集群]
$ ./kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic test_kafka --zookeeper chenx02:2181

#查看不可用的分区
$./kafka-topics.sh --describe --unavailable-partitions --zookeeper chenx02:2181 --topic  test_kafka

#发送消息
$ ./kafka-console-producer.sh --broker-list chenx02:9092 --topic test#消费消息
$ ./kafka-console-consumer.sh --zookeeper chenx02:2181 --topic test --from-beginning
返回列表