在CentOS上配置Kafka时,需要注意以下几个方面:
sudo yum install java-1.8.0-openjdk-devel
安装完成后,验证Java是否安装成功:java -version
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
tar -xzvf kafka_2.12-3.5.2.tgz -C /usr/local/kafka
server.properties
文件。以下是一些关键配置项:
broker.id
:每个Kafka broker的唯一标识。listeners
:Kafka监听的地址和端口。advertised.listeners
:Kafka对外暴露的地址和端口。log.dirs
:Kafka日志文件的存储路径。zookeeper.connect
:Zookeeper的地址和端口。security.inter.broker.protocol
:broker之间的安全协议,通常设置为SASL_PLAINTEXT
。sasl.enabled.mechanisms
:启用的认证机制,例如PLAIN
。ssl.truststore.location
和ssl.truststore.password
:用于SSL加密的证书路径和密码(如果需要)。zookeeper.properties
文件,设置数据目录和客户端端口等参数:dataDir /usr/local/kafka/zookeeper
clientPort 2181
然后启动Zookeeper服务:nohup /usr/local/kafka/bin/zookeeper-server-start.sh config/zookeeper.properties &
nohup /usr/local/kafka/bin/kafka-server-start.sh config/server.properties &
server.properties
文件,添加以下配置:listeners SASL_PLAINTEXT://your_server_ip:9092
security.inter.broker.protocol SASL_PLAINTEXT
sasl.enabled.mechanisms PLAIN
sasl.mechanism.inter.broker.protocol PLAIN
然后创建JAAS配置文件kafka_server_jaas.conf
,并启动Kafka时指定该文件:export KAFKA_OPTS="-Djava.security.auth.login.config=/path/to/kafka_server_jaas.conf"
./bin/kafka-server-start.sh config/server.properties
ulimit -n
设置足够大,调整vm.max_map_count
等。通过以上步骤和注意事项,可以在CentOS上成功配置和优化Kafka集群,确保其高可用性和高性能。