在Ubuntu上配置Kafka以使用Zookeeper涉及几个步骤。以下是详细的配置指南:
安装Zookeeper
- 下载Zookeeper:
wget https://archive.apache.org/dist/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
- 解压Zookeeper:
tar xvf zookeeper-3.4.6.tar.gz
- 移动到指定目录:
sudo mv zookeeper-3.4.6 /usr/local/zookeeper
配置Zookeeper
- 编辑配置文件:
sudo cat > /usr/local/zookeeper/conf/zoo.cfg << EOF tickTime=2000 dataDir=/var/lib/zookeeper clientPort=2181 EOF
- 创建数据和日志目录:
sudo mkdir /var/lib/zookeeper sudo mkdir /var/lib/zookeeper/log
- 启动Zookeeper:
sudo /usr/local/zookeeper/bin/zkServer.sh start
- 验证Zookeeper是否启动成功:
sudo netstat -nap | grep 2181
配置Kafka使用Zookeeper
- 下载Kafka:
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
- 解压Kafka:
tar -zvxf kafka_2.12-3.5.2.tgz
- 移动到指定目录:
sudo mv kafka_2.12-3.5.2 /usr/local/kafka
- 编辑Kafka配置文件:
- server.properties:
sudo vi /usr/local/kafka/config/server.properties
- 修改以下配置项:
broker.id=0 listeners=PLAINTEXT://:9092 log.dirs=/usr/local/kafka/log/kafka zookeeper.connect=localhost:2181
- 创建Kafka日志目录:
sudo mkdir /usr/local/kafka/log/kafka
- 启动Kafka:
sudo /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties
- 验证Kafka是否启动成功:
sudo netstat -nap | grep 9092
注意事项
- 确保Zookeeper和Kafka的配置文件中的
clientPort
和listeners
等端口不冲突。 - 如果使用Kafka 3.x及以上版本,Kafka实现了自己的分布式协调器,不再强制依赖Zookeeper,但可以在配置文件中保留
zookeeper.connect
以便于兼容旧版本。
以上步骤应该可以帮助你在Ubuntu上成功配置Kafka以使用Zookeeper。如果在配置过程中遇到任何问题,请检查日志文件以获取更多信息。