您的位置:首页 > 其它

一些基本操作

2015-03-25 14:02 120 查看
1.查看topic
bin/kafka-topics.sh --describe --zookeeper ip:2181/kafka-0.8.1
2.创建topic
bin/kafka-topics.sh --zookeeper ip:2181/kafka-0.8.1 --create --topic topicName --partitions 10 --replication-factor 3
3.删除topic
bin/kafka-topics.sh --delete --topic freq-test-26 -zookeeper 10.11.10.122:2181
4.添加partition
bin/kafka-topics.sh --alter --topic test001 --partitions 5 --zookeeper ip:2181/kafka-0.8.1
5.数据路径
/DATA/...
6.查看kafka实时数据
bin/kafka-console-consumer.sh --zookeeper ip/kafka-0.8.1 --topic topic_name | grep '5c9a89817e6041d72e1e256cad9cfb79' --color
7.启动kafka
JMX_PORT=9997 bin/kafka-server-start.sh config/server.properties > /dev/null 2>&1 &
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: