kafka安装使用

首先打个比方，kafka好比就是中央电视台，而中央电视台下面有很多节目，生产者就是制作节目的团队，而消费者就是我们观看这个节目的人，一开始中央电视台创建一个节目，假设就叫cctv1，创建后就要去zookeeper中注册一下，相当于给它申请了一个专利，有了这个节目名后，我们就得请一个团队来填充这个节目，比如拉广告啊，放电视剧之类的数据，而我们消费者要观看这个节目的话就得需要zookeeper来授权给我们。中央电视台则只是存数据的，相当于一个中间人，和现在中介差不多个意思。

了解了kafka的作用后我们就来安装和解压kafka

1 首先把我们下载好的kafka文件上传到hadoop目录然后解压到opt目录中

2 然后进入我们的opt下解压好的kafka目录 我们要取得不以#符合开头的信息 命令如下

 

3 然后vi到我们改名叫zk.properties的文件中然后更改里面的信息如下图

表示我们以后zookeeper记录的信息都在home/hadoop/zk/这个目录中

4 启动

5然后我们复制一个ssh通道 jps一下就可以看到启动了一个新的服务 也就是zookeeper的主进程

6启动borker

首先在新建的窗口输入以下命令查看以下

我们主要看这个地方 第一个是0 当启动了两个kafka就是1 可以连续不能重复

我们还是讲一个文件的数据复制到一个新的目录 将带有#注释的代码去掉

取名字叫做kafka1.properties （名字很low 可以叫小明）

然后启动

之后我们复制一个ssh通道jps一下就可以看到kafka已经启动成功了

7 创建一个主体（用的是kafka的主体也叫频道）

首先创建一个叫cctv1的主题

然后我们查看以下我们的cctv1主题创建好了没有 

出现了我们创建的cctv1 成功！

8现在需要有往cctv中灌输数据 发送一些消息

首先我们新建两个ssh通道 第一个里输入命令用来发布消息

然后再第二个新建的通道启动消费者 相当于订阅了这个cctv1的频道 用来接收消息

这样我们就可以收到刚刚发布的消息了！

但是我们现在只能收到刚刚发布的消息 如何可以接收以前的消息呢 

只需要在启动消费者的命令后面加入--from-beginning就可以了

9 自己制作一个python的kafka生产者和python版的kafka的消费者

当我没说 算了就这样吧