在Ubuntu上集成Kafka与Zookeeper是一个常见的任务,特别是在构建分布式流处理平台时。以下是一个详细的步骤指南,帮助你在Ubuntu系统上成功集成Kafka和Zookeeper。
Kafka是用Java编写的,因此首先需要安装Java环境。
sudo apt-get update
sudo apt-get install openjdk-17-jdk
java -version
从Apache Kafka和Zookeeper的官方网站下载适合Ubuntu版本的安装包,并解压到指定目录。
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
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
进入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
在dataDir
指定的目录下创建myid
文件,并写入相应的服务器编号。
mkdir -p /home/kafka/zookeeper
echo 1 > /home/kafka/zookeeper/myid
在Zookeeper的bin
目录下启动Zookeeper服务。
cd /home/kafka/zookeeper/bin
./zkServer.sh start
./zkServer.sh status
进入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-topics.sh --bootstrap-server 192.168.1.111:9092 --create --topic my-topic --partitions 3 --replication-factor 3
在Kafka的bin
目录下启动Kafka服务。
./kafka-server-start.sh config/server.properties
使用Kafka客户端连接到Kafka集群。
./kafka-topics.sh --bootstrap-server 192.168.1.111:9092 --list
通过以上步骤,你已经成功在Ubuntu上集成了Kafka和Zookeeper。请确保所有配置文件和路径都正确无误,并根据实际需求进行调整。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:kafka在ubuntu上怎样优化