117笔记问答在Ubuntu上集成Kafka与Zookeeper是一个常见的任务，特别是在构建分布式流处理平台时。以下是一个详细的步骤指南，帮助你在Ubuntu系统上成功集成Kafka和Zookeeper。
1. 安装Java环境
Kafka是用Java编写的，因此首先需要安装Java环境。
sudo apt-get update sudo apt-get install openjdk-17-jdk java -version
2. 下载并解压Kafka和Zookeeper
从Apache Kafka和Zookeeper的官方网站下载适合Ubuntu版本的安装包，并解压到指定目录。
下载Kafka
wget https://mirrors.aliyun.com/apache/kafka/3.7.0/kafka_2.13-3.7.0.tgz tar -xzf kafka_2.13-3.7.0.tgz mv kafka_2.13-3.7.0 kafkacd
下载Zookeeper
wget http://archive.apache.org/dist/zookeeper/zookeeper-3.6.6/apache-zookeeper-3.6.6.tar.gz tar -zxvf apache-zookeeper-3.6.6.tar.gz mv apache-zookeeper-3.6.6 zookeeper
3. 配置Zookeeper
修改Zookeeper配置文件
进入Zookeeper的配置目录并编辑zoo.cfg文件。
cd zookeeper cp zoo_sample.cfg zoo.cfg vim zoo.cfg
在zoo.cfg文件中添加或修改以下内容：
tickTime=2000 dataDir=/home/kafka/zookeeper clientPort=2181 initLimit=10 syncLimit=5 server.1=192.168.1.111:2888:3888 server.2=192.168.1.112:2888:3888 server.3=192.168.1.113:2888:3888
创建数据目录并添加myid文件
在dataDir指定的目录下创建myid文件，并写入相应的服务器编号。
mkdir -p /home/kafka/zookeeper echo 1 > /home/kafka/zookeeper/myid
4. 启动Zookeeper
在Zookeeper的bin目录下启动Zookeeper服务。
cd /home/kafka/zookeeper/bin ./zkServer.sh start ./zkServer.sh status
5. 配置Kafka
修改Kafka配置文件
进入Kafka的配置目录并编辑server.properties文件。
cd /home/kafka/kafkacd vim config/server.properties
在server.properties文件中添加或修改以下内容：
broker.id=1 listeners=PLAINTEXT://:9092 advertised.listeners=PLAINTEXT://192.168.1.111:9092 log.dirs=/home/kafka/log/kafka zookeeper.connect=192.168.1.111:2181
创建Kafka主题
使用Kafka提供的命令行工具创建主题。
./kafka-topics.sh --bootstrap-server 192.168.1.111:9092 --create --topic my-topic --partitions 3 --replication-factor 3
6. 启动Kafka
在Kafka的bin目录下启动Kafka服务。
./kafka-server-start.sh config/server.properties
7. 验证安装
使用Kafka客户端连接到Kafka集群。
./kafka-topics.sh --bootstrap-server 192.168.1.111:9092 --list
通过以上步骤，你已经成功在Ubuntu上集成了Kafka和Zookeeper。请确保所有配置文件和路径都正确无误，并根据实际需求进行调整。