-
- 一、脚本准备:从老师处拿到 logger.sh.zip
解压 unzip logger.sh.zip
进到该目录 cd logger
-
- 二、启动:nohup sh shelllogger.sh &
查看 access.log 和 nohup.out 启动后生成
cat access.log
nohup tail -f /home/stream/zookeeper/logger/access.log | bin/kafka-console-producer.sh --broker-list hadoop03:9092 --topic mytopic >logs/producer.log 2>&1 &
进入kafka目录
启动productor
bin/kafka-console-consumer.sh --zookeeper hadoop03:2181 --topic mytopic
启动consumer
bin/kafka-console-producer.sh --broker-list hadoop03:9092 --topic mytopic
可以看到
出现上述 证明成功
使用日志生成工具 验证kafaka 安装情况
原文:http://www.cnblogs.com/ailonglong/p/kafka.html