版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/su377486/article/details/77845379
1.环境说明
主机信息如下:
操作系统版本如下:
2.下载kafka
下载地址如下:
二.配置zookeeper
由于kafka需要使用到zookeeper来注册信息,因此需要首先配置zookeeper.在kafka的安装包中已经提供了zookeeper,不需要额外安装,直接配置一下即可.配置文件在config下的zookeeper. properties
三.配置kafka
kafka的配置文件在config下的server.properties文件.下面是一个配置实例:
4.启动kafka
为了方便可以将kafka的运行目录添加到PATH环境变量中.
首先使用命令bin/zookeeper-server-start.sh config/zookeeper.properties
启动zookeeper.
再使用命令bin/kafka-server-start.sh config/server.properties
启动kafka
5.模拟测试kafka发布订阅
新建一个窗口模拟producer,执行:
kafka-console-producer.sh --broker-list localhost:9092 --topic
然后在窗口中随便输入
在另外一个窗口中模拟consumer,执行:
[root@test1 ~]# kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1 --from-beginning
然后会发现producer的输入会实时的发布到consumer中
创建主题:
查看主题: