在CentOS环境下配置Kafka时,有几个关键点需要注意:
sudo yum install java-1.8.0-openjdk
java -version
tar -zxvf kafka_2.12-3.5.2.tgz
server.properties
文件:
broker.id
:确保每个Kafka broker的ID是唯一的。listeners
:指定Kafka监听的IP地址和端口。log.dirs
:指定Kafka日志存储的目录。zookeeper.connect
:指定Zookeeper的地址和端口。
示例配置:broker.id=1
listeners=PLAINTEXT://your_server_ip:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=zookeeper_ip:2181
firewall-cmd --zone=public --add-port=2181/tcp --permanent
firewall-cmd --zone=public --add-port=9092/tcp --permanent
firewall-cmd --reload
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
nohup bin/kafka-server-start.sh config/server.properties &
ps -ef | grep zookeeper
ps -ef | grep kafka
bin/kafka-topics.sh --create --topic test --bootstrap-server your_server_ip:9092 --replication-factor 1 --partitions 1
bin/kafka-console-producer.sh --topic test --bootstrap-server your_server_ip:9092
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server your_server_ip:9092
通过以上步骤和注意事项,可以在CentOS环境下成功配置Kafka,并确保其稳定性和性能。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:kafka配置centos要注意啥