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 |
相关文章推荐
- IndexedDB:浏览器里内置的数据库(转)
- [好文要转]【关于block使用的5点注意事项】
- select/**/*/**/from/**/RegSite
- Dynamic Programming - Part2
- KAFKA学习总结
- 深入理解kafka设计原理
- 什么是静态地址重定位,它需要什么支持?什么是动态地址重定位,他需要什么支持?静态地址重定位与动态地址重定位有什么区别?
- javascript学习之JSON
- SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
- Java中Timer的用法
- 文章标题
- uva 10806 Dijkstra, Dijkstra. (最小费最大流)
- cuda未定义标识符等一些问题
- BASH中的内置变量
- 网络扫描工具nc&nmap
- Spark 学习资源收集【Updating】
- 配置Jenkins邮件
- git 常用操作
- 7-22关于agriculture-mvc的理解与完善,通过关键字模糊查询
- win7远程桌面连接ubuntu14.04