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的关键配置文件,需重点设置以下参数:
- broker.id:集群中每个broker的唯一标识(整数,不可重复);
- listeners:broker监听的地址和端口(如
PLAINTEXT://your_server_ip:9092,用于客户端连接); - advertised.listeners:对外暴露的地址和端口(集群环境下需设置为公网IP或域名,确保其他节点能访问);
- log.dirs:Kafka日志(消息数据)的存储目录(如
/tmp/kafka-logs,需提前创建且具备写入权限); - zookeeper.connect:Zookeeper集群的连接地址(如
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的
broker.id(唯一); listeners和advertised.listeners(指向当前节点的IP);zookeeper.connect(包含所有Zookeeper节点的地址);- 在每台服务器的
dataDir目录下创建myid文件(内容为对应broker.id),用于集群识别。
以上就是关于“ubuntu中kafka配置有哪些关键点”的相关介绍,筋斗云是国内较早的云主机应用的服务商,拥有10余年行业经验,提供丰富的云服务器、租用服务器等相关产品服务。云服务器资源弹性伸缩,主机vCPU、内存性能强悍、超高I/O速度、故障秒级恢复;电子化备案,提交快速,专业团队7×24小时服务支持!
简单好用、高性价比云服务器租用链接:https://www.jindouyun.cn/product/cvm