Kafka常用操作

原创
2014/04/17 17:09
阅读数 3.4K

Kafka的版本间差异较大,下面是0.8.1的操作方法

首先cd到kafaka的bin目录下,操作kafka的工具都在这里呢。如果发现找不到,或者名字不对,说明kafka版本不对。

以topic是test为例子 --zookeeper 后的ip改成你们自己的

创建topic ./kafka-topics.sh --topic test --create --partitions 2 --replication-factor 1 --zookeeper 10.234.10.17:2181,10.234.10.20:2181 partitions 为分区数,0.8.1默认就是2 replication-factor:为复制因子,也就是副本数

查看所有topic ./kafka-topics.sh --list --zookeeper 10.234.10.17:2181,10.234.10.20:2181

删除topic ./kafka-topics.sh --topic test --delete --zookeeper 10.234.10.17:2181,10.234.10.20:2181

查看topic明细 ./kafka-topics.sh --topic test --describe --zookeeper 10.234.10.17:2181,10.234.10.20:2181

查看不可用分区 ./kafka-topics.sh --topic test --describe --unavailable-partitions --zookeeper 10.234.10.17:2181,10.234.10.20:2181 不知道什么原因就会导致部分分区不可用,用这个命令可以查看。

展开阅读全文
加载中
点击引领话题📣 发布并加入讨论🔥
0 评论
7 收藏
1
分享
返回顶部
顶部