在Kafka搭建时,首先安装zookeeper,新版本直接解压,启动就好了。由于什么原因,在虚拟机下,必须用root账户启动zookeeper,不然其中一个文件由于没有权限无法创建,导致zookeeper启动失败。

在开启虚拟机方面,遇到两个问题,第一个是本地主机无法连接虚拟机,解决方法是修改etc文件夹下的相关配置文件,静态(static)配置虚拟机ip使虚拟机网段和主机网段相同。第二个是jdk配置环境时导致虚拟机开机失败,总是循环在登录界面,无法进入虚拟机。首先按alt+ctrl+f1~f4进入命令行模式,利用cd 和usr/bin/vim 编辑etc/profile文件 ,使相关配置准确。

启动Kafka,首先要配置Kafka的配置文件,然后启动。设置新的主题,开启生产者和消费者。这里不再写相关命令

spring boot配置Kafka时出现一个问题,就是向虚拟机上的卡夫卡发送消息时报

WARN Connection to node 0 could not be established. Broker may not be available. (org.apache.kafka.c

错误,这是因为要配置Kafka的配置文件server.properties

注释掉listeners配置:

#listeners=PLAINTEXT://127.0.0.1(或者是本地ip地址):9092

重新启动Kafka,就不会报错了

版权声明:本文为2huo原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/2huo/p/11162236.html