搭建3个节点的hadoop集群（完全分布式部署）4 安装scala与kafka

先只是安装在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窗口就可以看到显示。