您的位置:

Ubuntu下安装Kafka详细步骤

一、安装Java环境

1、首先检查操作系统中是否已经安装好了Java环境。在终端输入命令:

java -version

如果操作系统尚未安装Java环境,会提示“Command not found”的信息。

2、安装OpenJDK:

sudo apt-get update
sudo apt-get install openjdk-8-jdk

3、验证Java安装是否成功:

java -version

验证成功后,会显示Java的版本信息。

二、下载和解压缩Kafka

1、前往Apache Kafka官网下载kafka的压缩包,最好选择稳定版本:

https://kafka.apache.org/downloads

2、下载完成后,进入下载目录,解压缩该文件:

tar -xzf kafka_2.13-2.8.0.tgz

3、切换到Kafka目录:

cd kafka_2.13-2.8.0

三、启动Kafka服务器

1、我们需要启动3个Kafka服务,Zookeeper服务和两个Broker服务:

bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

再启动一个Broker节点

bin/kafka-server-start.sh config/server-1.properties

再启动一个服务

bin/kafka-server-start.sh config/server-2.properties

这样就启动好了Kafka服务器

四、创建topic

1、使用如下命令创建一个名为test的topic:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test

其中,--replication-factor表示副本因子,即一个消息被保存在几个Broker节点上,--partitions表示分区数,可根据需求来定。

2、使用如下命令查看已存在的topic列表:

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

五、启动生产者和消费者

1、启动生产者:

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

输入消息后,回车即可发送至Kafka。

2、启动消费者:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

--from-beginning代表从头开始消费。

六、清除数据和关闭服务

1、清除数据:

rm -rf /tmp/kafka-logs/*

2、关闭Kafka服务:

bin/kafka-server-stop.sh

3、关闭Zookeeper服务:

bin/zookeeper-server-stop.sh

总结

本篇文章简要介绍了在Ubuntu上安装Apache Kafka的详细步骤,包括安装Java环境、下载和解压缩Kafka、启动Kafka服务器、创建topic、启动生产者和消费者等。