在Debian上配置Kafka集群,可参考以下步骤:
- 安装Java:使用
sudo apt update和sudo apt install openjdk-8-jdk命令安装OpenJDK 8,并通过java -version验证安装。 - 安装Zookeeper:从Apache官网下载Zookeeper安装包,解压后复制
zoo_sample.cfg为zoo.cfg,编辑该文件,设置dataDir、clientPort和server.x等参数,然后在每个节点上启动Zookeeper。 - 安装Kafka:下载Kafka安装包并解压,将解压后的目录移动到指定位置,如
/opt/kafka。 - 配置Kafka:在每个Kafka节点的
config目录下,编辑server.properties文件,设置broker.id为唯一值,配置listeners、log.dirs和zookeeper.connect等参数。 - 启动Kafka集群:在每个节点上使用
bin/kafka-server-start.sh config/server.properties命令启动Kafka服务。 - 验证集群:使用
kafka-topics.sh等命令行工具创建主题、查看主题详情,以验证集群是否正常运行。