Kafka在Ubuntu上如何安装

ubuntu

小樊

2025-03-03 06:06:09

栏目: 智能运维

在Ubuntu上安装Apache Kafka的步骤如下：

1. 安装Java开发工具包（JDK）

首先，确保你的系统上已经安装了JDK。你可以通过以下命令安装JDK 8：

sudo apt update
sudo apt install openjdk-8-jdk

安装完成后，验证JDK是否安装成功：

java -version

2. 安装Apache Zookeeper

Kafka依赖于Zookeeper，因此你需要先安装Zookeeper。你可以从Apache官网下载Zookeeper的安装包，并解压到指定目录。

wget https://archive.apache.org/dist/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
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

启动Zookeeper服务：

sudo /usr/local/zookeeper/bin/zkServer.sh start

验证Zookeeper是否启动成功：

sudo netstat -nap | grep 2181

3. 安装Kafka

下载Kafka安装包并解压到指定目录。你可以从Apache官网下载Kafka的安装包。

wget https://archive.apache.org/dist/kafka/0.9.0.1/kafka_2.11-0.9.0.1.tgz
tar xvf kafka_2.11-0.9.0.1.tgz
sudo mv kafka_2.11-0.9.0.1 /usr/local/kafka
sudo mkdir /tmp/kafka-logs

配置Kafka：

sudo cp /usr/local/kafka/config/server.properties /usr/local/kafka/config/server.properties.example
sudo vi /usr/local/kafka/config/server.properties

在server.properties文件中，修改以下配置项：

broker.id：设置为你的Kafka broker ID。
listeners：设置为你的Kafka监听地址和端口。
log.dirs：设置为你的Kafka日志目录。
zookeeper.connect：设置为你的Zookeeper地址和端口。

启动Kafka服务：

sudo /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties

验证Kafka是否启动成功：

sudo netstat -nap | grep 9092

4. 创建和测试Topic

创建一个名为test的Topic：

sudo /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

列出所有Topic以确认新Topic已创建：

sudo /usr/local/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181

启动生产者发送消息：

sudo /usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

在另一个终端启动消费者接收消息：

sudo /usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

至此，你已经成功在Ubuntu上安装了Kafka，并进行了简单的测试。

亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>