1、首先,我们需要喉哆碓飙去对应网站下载cdh的kafka的相关包,下载的链接如下:csd包:http://archive.cloudera.com/csds/ka熠硒勘唏fka/parcel包:http://archive.cloudera.com/kafka/parcels/latest/注:parcel下的kafka相关文件根据你自己对应的版本来下具体操作下图均有详细介绍
2、下好后总共是4个文件,接下来就开始正式安装kafka了,首先将cdh原有的kafka删除(没有则忽略),将csd包放到c罪焐芡拂m安装节点下的 /opt/cloudera/csd目录下,这里放的就是kafka开头的那个jar,将parcel包下的文件放到cm安装节点下的/opt/cloudera/parcel-repo目录下面,就是剩下的那三个文件。这里需要注意一下的是,如果在目录下已经有这些文件了,最好把他重命名一下,防止误操作,覆盖有用文件。
3、启动你的cm服务,如果已经启动了就直接在主机界面的parcel,检查更新parcel,分配并激活你的percel名为kafka的包,具体操作下图有详细说明。
4、到这里我们就已经成功了一半了,现在就开始在cdh添加我们激活好的kafka组件了。按照下图步骤走,先添加服务,选kafka,分配kafka服务到需要分配的机器,我这里是安装了6台,具体安装几台机器根据个人情况决定。
5、分配好组件的机器后,下面可能会出现报错启动不了的情况,这里根据本人安装的错误经验来说一般有这样两种情况。1.Broke节点报错:进入下面目录修改brokeid,默认都为0,需要修改成不同的如:0,1,22.字节设置太小,到对应位置设置成1G的,可直接搜其key的名字找到对应参数修改具体操作下图有说明。
6、修改好之后,再一步一步来就可以直接启动了成功了。