一、前提条件和环境
1、环境：CDH5.16.x|Centos7.x|scala 2.11
2、CM和CDH环境已经搭建完成。在CDH上集成Kafka，要求用CDH上的Zookeeper管理Kafka。
二、相关软件下载
cloudera官网kafka：
https://docs.cloudera.com/documentation/kafka/latest/topics/kafka_packaging.html
简要说明：例如kafka_2.11-2.2.1-kafka-4.1.0.jar
2.11 scala 版本
2.2.1 apache kafka版本
4.1.0 cdk版本
下载下面的三个文件（Linux版本是6系列，选择el6，7系列选择el7）
1、在/var/www/html/（http服务的默认目录）新建文件夹kafka_parcel。
mkdir kafka_parcel
2、将上面的三个文件上传到该目录下，并将KAFKA-4.1.0-1.4.1.0.p0.4-el7.parcel.sha1重命名为KAFKA-4.1.0-1.4.1.0.p0.4-el7.parcel.sha。
三、安装过程
1、添加Kafka服务
2、安装Parcel
配置：下载-》分配-》激活
Kafka parcel激活完成！
3、集群添加kafka服务安装：
Missing required value: Destination Broker List
Missing required value: Source Broker List
可按如下方法配置即可：
a. 填写Source Brokers List
填写Kafka Broker所在节点构成的列表（用逗号分隔），如下（所有节点部署了Kafka Broker）：
master:9092,slave1:9092,slave2:9092
b. 填写Destination Brokers List
若添加了Kafka MirrorMaker，则可填写其所在节点构成的列表；若未添加Kafka MirrorMaker，可填写任意服务器即可，如下：
master:9092,slave1:9092,slave2:9092
或：example.com:9092
完成配置后继续下一步，完成安装！
4、whitelist must be specified报错（配置了Kafka MirrorMaker角色），在配置界面搜索whitelist添加机器：
四、测试Kafka
cd /opt/cloudera/parcels/KAFKA/bin/
./kafka-topics --create --zookeeper bigdata001:2181 --replication-factor 3 --partitions 3 --topic zyl_test
模拟生产者
./kafka-console-producer --broker-list bigdata001:9092 --topic zyl_test
模拟消费者
./kafka-console-consumer --bootstrap-server bigdata001:9092 --topic zyl_test --from-beginning