kafka部署

kafka版本： kafka_2.11-1.1.0.tgz 去官网下载

将kafka放在opt下然后解压

tar -zxvf kafka_2.11-1.1.0.tgz

解压好进入到kafka目录下:

因为zookeeper.properties注释实在太多，所以我通过grep命令查找到kafka非注释的字符串，并把它追加到 zk.properties中:

去修改配置文件：

因为zookeeper.properties注释实在太多，所以我通过grep命令查找到kafka非注释的字符串，并把它追加到 zk.properties中。

然后去修改zk.properties

只需要修改第一行

启动zookeeper:

复制一个SSH通道：

同zookeeper相同，筛选一下server.properties并把它追加到kafka1.properties中

OK之后启动kafka:

./bin/kafka-server-start.sh config/kafka1.properties

创建一个主题：

启动生产者（producer）

在生产者中发送的消息，会存储在broker中，需要消费者接收这些消息。

启动消费者：

消费者接收到了生产者发的消息

也可以用python写生产者消费者：

写了一个生产者代码，我这是在pycharm里写的然后传过来的，写的时候需要安装kafka pip install kafka

启动生产者：

消费者代码：

启动消费者：

生产者给消费者发消息就能收到了