在Debian系统上配置Kafka的关键步骤如下:
Kafka是用Scala和Java编写的,因此需要先安装Java运行环境。
sudo apt update
sudo apt install openjdk-8-jdk
安装完成后,可以使用以下命令验证Java是否安装成功:
java -version
可以从Apache Kafka官网下载Kafka的安装包,然后使用tar
命令解压。
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
tar -zvxf kafka_2.12-3.5.2.tgz
在环境变量中指定Kafka的安装目录以及命令文件所在目录。可以在/etc/profile
文件最下方添加如下两行命令来配置全局环境变量:
export KAFKA_HOME=/path/to/kafka
export PATH=$PATH:$KAFKA_HOME/bin
然后,使配置生效:
source /etc/profile
在Kafka 2.8.0版本以后,引入了Kraft模式,可以不依赖外部Zookeeper运行。但如果需要使用Zookeeper,可以按照以下步骤进行配置和启动:
wget https://downloads.apache.org/zookeeper/zookeeper-3.8.0/apache-zookeeper-3.8.0-bin.tar.gz
tar -zxvf apache-zookeeper-3.8.0-bin.tar.gz
export ZK_HOME=/path/to/zookeeper
export PATH=$PATH:$ZK_HOME/bin
在$ZK_HOME/conf/zoo.cfg
文件中配置Zookeeper的配置信息,然后启动Zookeeper:
./bin/zkServer.sh start
进入Kafka的安装目录,然后启动Kafka Broker:
cd /path/to/kafka
./bin/zookeeper-server-start.sh config/zookeeper.properties
./bin/kafka-server-start.sh config/server.properties
可以使用以下命令来验证Kafka是否安装成功:
./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果看到列出的topic,则表示Kafka安装成功。
以上就是在Debian系统上配置Kafka的关键步骤。在配置过程中,还需要根据实际需求进行相应的调整和优化。
辰迅云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读: Debian HDFS与其他分布式文件系统比较