您的位置:首页 > 其它

flume、kafka、storm常用命令

2015-07-22 15:37 288 查看
flume、kafka、storm常用命令

一些常用命令:

storm相关:

storm nimbus >/dev/null 2>&1 &

storm supervisor >/dev/null 2>&1 &

storm ui >/dev/null 2>&1 &

关闭storm

ps -ef|grep apache-storm-0.9.2-incubating|grep -v grep|awk '{print $2}'|xargs kill -9

kafka相关:

复制代码

启动kafka

./kafka-server-start.sh ../config/server.properties

生产消息

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic kafkaTopic

消费消息

./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic kafkaTopic --from-beginning

创建topic(副本数和分区数)

./kafka-topics.sh --topic kafkaTopic --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partition 6

修改topic

./kafka-topics.sh -topic kafkaTopic -alter -zookeeper 127.0.0.1:2181 --partition 6

查看单个topic详细

./kafka-topics.sh -topic kafkaTopic -describe -zookeeper 127.0.0.1:2181

查看所有topic

bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181

复制代码

flume相关:

启动flume

./flume-ng agent --conf ../conf --conf-file ../conf/flume-conf.properties --name producer

查flume进程

ps -ef | grep flume
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: