在CentOS上快速部署Kafka可以分为几个步骤,包括安装必要的软件、配置Zookeeper和Kafka、启动服务以及验证部署。以下是一个详细的指南:
Kafka需要Java运行环境,首先确保你的系统上已经安装了Java。
sudo yum install java-1.8.0-openjdk-devel -y
java -version
从Apache Kafka官网下载适合的版本,然后解压到指定目录。例如,下载Kafka 3.5.2版本:
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
tar -zxvf kafka_2.12-3.5.2.tgz -C /usr/local/kafka/
cd /usr/local/kafka/
Kafka依赖Zookeeper来进行集群管理和协调。
vi /usr/local/kafka/config/zookeeper.properties
修改以下参数:
dataDir
: Zookeeper数据存储目录,例如 /usr/local/kafka/zookeeper_data
clientPort
: Zookeeper客户端连接端口,例如 2181
nohup /usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties &
vi /usr/local/kafka/config/server.properties
修改以下关键配置项:
broker.id
: 每个Kafka broker的唯一标识,例如 0
listeners
: Kafka监听的地址和端口,例如 PLAINTEXT://your_server_ip:9092
advertised.listeners
: Kafka对外暴露的地址和端口,例如 PLAINTEXT://your_server_ip:9092
log.dirs
: Kafka日志文件的存储路径,例如 /usr/local/kafka/kafka-logs
zookeeper.connect
: Zookeeper的地址和端口,例如 localhost:2181
nohup /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/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
如果你需要部署多个Kafka实例,可以按照以下步骤进行:
config/server.properties
文件中的 listeners
和 advertised.listeners
以指向不同的IP地址和端口。