作者：书友35194403 | 来源：互联网 | 2024-11-18 17:41
一、准备工作
确保你有一台运行CentOS 7的虚拟机，并安装了FinalShell等SSH工具。
二、安装配置
1. JDK配置：编辑 /etc/profile 文件，添加以下内容并保存：
export JAVA_HOME=/usr/local/jdk1.8.0_291
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib:$CLASSPATH
export JAVA_PATH=${JAVA_HOME}/bin:${JRE_HOME}/bin
export PATH=$PATH:${JAVA_PATH}
使配置生效：
2. Zookeeper配置：复制 zoo_sample.cfg 到 zoo.cfg：
cp zoo_sample.cfg zoo.cfg
编辑 zoo.cfg 文件，添加以下内容以避免端口冲突：
创建Zookeeper的数据目录：
mkdir -p /path/to/zookeeper/data
启动Zookeeper服务：
3. Kafka配置：下载Kafka的二进制包（不要下载源码包），解压后编辑 config/server.properties 文件，配置Zookeeper地址：
zookeeper.cOnnect=localhost:2181
启动Kafka服务：
kafka-server-start.sh config/server.properties &
创建测试Topic：
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看所有Topic：
kafka-topics.sh --list --zookeeper localhost:2181
生产消息：
kafka-console-producer.sh --broker-list localhost:9092 --topic test
消费消息：
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
京公网安备 11010802041100号