先只是安装在elephant节点上.
先下载scala与kafka并解压放到/opt目录下面,版本如下：
kafka_2.10-0.8.2.1.tgz
scala-2.11.8.tgz
在/etc/profile设置scala的目录
启动kafka
bin/kafka-server-start.sh config/server.properties
新建topic
bin/kafka-topics.sh --create --topic kafkatopic --replication-factor 1 --partitions 1 --zookeeper elephant:2181
启动producer
bin/kafka-console-producer.sh --broker-list elephant:9092 --sync --topic kafkatopic
启动consumer
bin/kafka-console-consumer.sh --zookeeper elephant:2181 --topic kafkatopic --from-beginning
然后在producer窗口输入内容，在consumer窗口就可以看到显示。