Flume
# flume启动
bin/flume-ng agent -n fks -c conf/ -fconf/ytconf/fks/fks001.conf -Dflume.root.logger=INFO,console &
Kafka
# 启动kafka自带的zookeeper(当然也可以使用外部的)
bin/zookeeper-server-start.sh config/zookeeper.properties &
# 启动外部的zookeeper
1. 启动ZK服务: sh bin/zkServer.sh start 2. 查看ZK服务状态: sh bin/zkServer.sh status 3. 停止ZK服务: sh bin/zkServer.sh stop 4. 重启ZK服务: sh bin/zkServer.sh restart
# 启动kafka的server
bin/kafka-server-start.sh config/server.properties &
# 创建一个主题
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test &
# 查看创建的主题
bin/kafka-topics.sh--list --zookeeper localhost:2181
# send some message(发送一些消息)
输入一条信息(Thisis a message: The you smile until forever),并且Ctrl+z退出shell
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
# start a consumer
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
# 删除以前的topic
bin/kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic test666 --zookeeper 192.168.197.170:218,192.168.197.171:2181
Storm
# storm的启动
# storm nimbus的启动
bin/storm nimbus &
# storm supervisor的启动
bin/storm supervisor &
# storm ui的启动
bin/storm ui &
# storm jar命令运行storm程序
storm jar fks-storm-high-001.jar com.yting.cloud.storm.topology.KafkaTopology
原文:http://my.oschina.net/drl/blog/515292