kafka搭建相关可能出现的bug
在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,就不会报错了