1. Java环境配置
Kafka基于Java开发,需提前安装JDK(推荐OpenJDK 8)。通过sudo apt install openjdk-8-jdk安装后,用java -version验证安装是否成功,确保Kafka能正常启动。
2. Zookeeper依赖配置
Kafka依赖Zookeeper实现集群管理和元数据存储。需先下载并解压Zookeeper(如wget https://archive.apache.org/dist/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz),编辑zoo.cfg配置文件(设置dataDir为数据目录、clientPort为客户端端口,默认2181),启动Zookeeper服务(zkServer.sh start),并通过netstat -nap | grep 2181验证端口是否监听。
3. Kafka核心配置(server.properties)
server.properties是Kafka的关键配置文件,需重点设置以下参数:
PLAINTEXT://your_server_ip:9092,用于客户端连接);/tmp/kafka-logs,需提前创建且具备写入权限);localhost:2181,多节点用逗号分隔)。4. 环境变量配置
为方便使用Kafka命令,需将Kafka的bin目录添加到系统PATH中。编辑/etc/profile文件,添加export KAFKA_HOME=/usr/local/kafka(Kafka安装路径)和export PATH=$PATH:$KAFKA_HOME/bin,执行source /etc/profile使配置生效。
5. 防火墙配置
若系统启用了防火墙(如ufw),需开放Kafka和Zookeeper的默认端口(9092、2181),允许外部访问。命令示例:sudo ufw allow 9092/tcp、sudo ufw allow 2181/tcp,然后执行sudo ufw reload使规则生效。
6. 开机自启配置(可选但推荐)
通过systemd配置Kafka和Zookeeper开机自动启动,避免手动重启。创建/lib/systemd/system/zookeeper.service和/lib/systemd/system/kafka.service文件,定义服务依赖(如Kafka依赖Zookeeper)和启动命令,执行systemctl daemon-reload加载配置,再用systemctl enable zookeeper、systemctl enable kafka设置开机自启。
7. 集群配置(可选扩展)
若需搭建Kafka集群,需在多台Ubuntu服务器上重复上述步骤,重点调整:
broker.id(唯一);listeners和advertised.listeners(指向当前节点的IP);zookeeper.connect(包含所有Zookeeper节点的地址);dataDir目录下创建myid文件(内容为对应broker.id),用于集群识别。