在选择和安装 Apache Kafka 版本时,有几个关键因素需要考虑,以确保系统稳定性、兼容性和未来扩展性。以下是一些建议:
性能需求:
兼容性:
新特性:
社区和生态:
系统依赖性:
单点故障和性能瓶颈:
Kafka 版本采用“大版本-小版本-patch版本”的命名规则,例如 kafka_2.12-3.5.2
。
例如,Kafka 3.x 系列是目前最新的稳定版,提供了许多新特性和性能改进,适合需要高可用性和高性能的场景。
安装 Java 环境:
sudo yum install java-1.8.0-openjdk-devel -y
下载并解压 Kafka:
wget https://archive.apache.org/dist/kafka/3.9.0/kafka_2.12-3.9.0.tgz
tar -xzf kafka_2.12-3.9.0.tgz
sudo mv kafka_2.12-3.9.0 /opt/kafka
配置环境变量:
echo 'export PATH=/opt/kafka/bin:$PATH' >> ~/.bashrc
source ~/.bashrc
修改配置文件:
编辑 server.properties
文件,配置 Kafka 服务器的相关参数,如 broker.id
, listeners
, log.dirs
, zookeeper.connect
等。
启动 Kafka 服务:
cd /opt/kafka
./bin/zookeeper-server-start.sh ../config/zookeeper.properties
./bin/kafka-server-start.sh ../config/server.properties
验证配置: 创建一个主题并测试:
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
通过综合考虑上述因素和步骤,您可以在 CentOS 上选择并安装适合您业务需求的 Kafka 版本。