欢迎光临散文网 会员登陆 & 注册

kafka

2023-07-16 00:34 作者:loveppop  | 我要投稿

kafka配置的问题困扰了我好几天,最后把所有情况都尝试了一遍才成功,单体启动的server.properties.

重要的一共就三个:

broker.id ,这个必须是唯一的,单体启动时不用修改,集群时一定要修改其他配置文件broker.id。

listener,这个是kafka的监听地址,“listeners=PLAINTEXT://0.0.0.0:9092”,我这里本来配置的是localhost,然后一直报错,最后改为0.0.0.0才成功,--bootstrap-server 的参数 就是这里配置的地址。查了一下 0.0.0.0和127.0.0.1的区别--省略---

advertised.listeners,,,"advertised.listeners=PLAINTEXT://host:9092",  host是云服务器的地址,配置这个属性外部才可以访问服务器的kafka。


上面两个变量用于解决组件或者应用网络连接问题。


出现的其他问题:

 *audit.*.disable* ,解决  : 在 zookeeper.properties中添加:audit.enable=true。

kafka和jdk版本不匹配,服务器本来安装的jdk19,结果怎么尝试都报错,最后换jdk11 又重新把所有的配置组合试了一遍才成功。


权限问题,配置正确,jdk版本正确,尝试将用户切换到root 再尝试一遍。我最终是 将jdk版本切换到jdk11 用root用户才成功。




kafka的评论 (共 条)

分享到微博请遵守国家法律