kafka 遇到的問題

1. Java 消費端消費報錯 “No entry found for connection 1” 和 Connection to node 1

解決辦法：https://blog.csdn.net/qq_33126131/article/details/104756834

Java 端實現 kafka 生產者與消費者，kafka 服務在雲服務器 。當消費者消費消息報錯，需要修改kafka  的 server.properties 配置

advertised.listeners=PLAINTEXT://IP:9092

ip 為雲服務器外網ip ,改配置默認是被注釋的

2.雲服務器搭建 zk+kafka 集群，內存不夠用，無法啟動

雲服務器搭建3個zk 集群，3個kafka,配置是 1核-2G +50G硬盤，3個zk 正常啟動，卡夫卡只能啟動一個，第二個啟動就會報錯內存不夠用

解決辦法：vim kafka-server-start.sh

 

 因為kafka 啟動便設置堆內存 1G ，改為 255M 即可啟動