日志收集

• 启动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