- 启动ZK集群，内容如下所示：
zkServer.sh start
注意：分别在ZK的节点上启动。
- 启动Kafka集群
kafka-server-start.sh config/server.properties &
在其他的Kafka节点输入同样的命令，完成启动。
- 启动Kafka监控工具
|
1
2
3
4
5
6
|
java -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk dn1:2181,dn2:2181,dn3:2181 --port 8089 --refresh 10.seconds --retain 1.days |
- 启动Flume集群
flume-ng agent -n producer -c conf -f flume-kafka-sink.properties -Dflume.root.logger=ERROR,console