Ubuntu22.04下安装kafka_2.12-2.6.0并运行简单实例-EW帮帮网

sudo tar -zxf ~/下载/kafka_2.12-2.6.0.tgz -C /usr/local
cd /usr/local
sudo mv kafka_2.12-2.6.0 kafka
sudo chown -R hadoop ./kafka    # 此处的 hadoop 为你的用户名

sudo tar -zxf ~/下载/kafka_2.12-2.6.0.tgz -C /usr/local：

使用 sudo 权限解压缩并解包 Kafka 压缩包文件 kafka_2.12-2.6.0.tgz
-zxf 参数表示使用 gzip 解压缩，并且是解包操作
~/下载/kafka_2.12-2.6.0.tgz 是 Kafka 压缩包的路径
-C /usr/local 指定了解压缩后的文件应该放置的目标路径为 /usr/local

cd /usr/local：

切换当前工作目录到 /usr/local

sudo mv kafka_2.12-2.6.0 kafka：

使用 sudo 权限将 Kafka 解压后的文件夹 kafka_2.12-2.6.0 重命名为 kafka

sudo chown -R hadoop ./kafka：

使用 sudo 权限递归地更改 kafka 文件夹及其所有子文件和子文件夹的所有者为 hadoop 用户
-R 参数表示递归地更改权限

至此，Kafka安装完成，下面在Ubuntu系统环境下测试简单的实例

三、启动Kafka并测试Kafka是否正常工作

1. 启动Kafka

打开第一个终端，输入下面命令启动Zookeeper服务：

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

千万不要关闭这个终端窗口，一旦关闭，Zookeeper服务就停止了（Kafka工作运行完毕后不再使用时再关闭）

打开第二个终端，然后输入下面命令启动Kafka服务：

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

千万不要关闭这个终端窗口，一旦关闭，Kafka服务就停止了（Kafka工作运行完毕后不再使用时再关闭）

成功启动所有服务后，读者将拥有一个基本的 Kafka 环境，可供使用。

2. 测试Kafka是否正常工作

主题（Topics）类似于文件系统中的文件夹，事件(events)是该文件夹中的文件。因此，在编写第一个事件之前，必须创建一个主题。

再打开第三个终端，然后输入下面命令创建一个自定义名称为“wordsendertest”的Topic（主题）：

cd /usr/local/kafka
# 创建一个名为 wordsendertest 的 Kafka 主题
./bin/kafka-topics.sh --create --topic wordsendertest --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
# 列出所有主题
./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
# 描述特定主题的细节
./bin/kafka-topics.sh --describe --topic wordsendertest --bootstrap-server localhost:9092

kafka-topics.sh：指定用于创建、列出和管理 Kafka 主题的脚本
--create：表示创建一个新的主题
--topic wordsendertest：指定要创建的主题名称，这里是 wordsendertest
--bootstrap-server localhost:9092：指定 Kafka 服务器的地址和端口。此处的localhost:9092表示本地的 Kafka 服务器，默认端口是9092
--replication-factor 1：设置副本因子为 1，意味着数据只有一个副本（不容错）
--partitions 1：设置分区数为 1，意味着只有一个分区
--describe：用于获取某个主题的详细信息

Kafka客户端通过网络与Kafka代理进行通信，以写入（或读取）事件。一旦收到事件，直到需要事件，代理程序都将以持久和容错的方式存储事件，甚至永远。

下面用生产者（Producer）来产生一些数据，在主题中写入一些事件。默认情况下，输入的每一行都将导致一个单独的事件写入主题。请在第三个终端（记作“数据源终端”）内继续输入下面命令：

cd /usr/local/kafka
./bin/kafka-console-producer.sh --topic wordsendertest --bootstrap-server localhost:9092

kafka-console-producer.sh：这是 Kafka 提供的一个用于生产者的控制台工具脚本
--topic wordsendertest：指定要创建的主题名称，这里是 wordsendertest
--bootstrap-server localhost:9092：指定 Kafka 服务器的地址和端口。此处的localhost:9092表示本地的 Kafka 服务器，默认端口是9092

当执行这个命令后，控制台会等待读者输入消息。每输入一行消息，它就会将该消息发送到指定的主题中。读者可以通过按下 Ctrl+C 来退出生产者控制台。

上面命令执行后，就可以在当前终端内用键盘输入一些英文单词（也可以等消费者启用后再输入）

现在可以启动一个消费者（Consumer），来查看刚才生产者产生的数据。请另外打开第四个终端，输入下面命令：

cd /usr/local/kafka
./bin/kafka-console-consumer.sh --topic wordsendertest --from-beginning --bootstrap-server localhost:9092

kafka-console-consumer.sh：这是 Kafka 提供的一个用于消费者的控制台工具脚本
--topic wordsendertest：指定要创建的主题名称，这里是 wordsendertest
--from-beginning：这个选项表示从该主题的起始位置开始消费消息。如果不指定这个选项，消费者将只会消费自启动后发布的消息
--bootstrap-server localhost:9092：指定 Kafka 服务器的地址和端口。此处的localhost:9092表示本地的 Kafka 服务器，默认端口是9092

执行这个命令后，控制台将开始从 wordsendertest 主题中消费消息，并将其显示在控制台上。读者可以通过按下 Ctrl+C 来退出消费者控制台。

因为事件是持久存储在Kafka中的，所以它们可以被任意多次读取，也可以被任意多的消费者读取。可以通过打开另一个终端会话并再次运行该命令来验证这一点

-> 实例运行结束后可以Ctrl+Z或Ctrl+C停止进程 ~~~

Ubuntu22.04下安装kafka_2.12-2.6.0并运行简单实例

一、版本信息

二、安装Kafka

1. 将Kafka安装包移到下载目录中

2. 安装Kafka并确保hadoop用户对Kafka目录有操作权限

三、启动Kafka并测试Kafka是否正常工作

1. 启动Kafka

2. 测试Kafka是否正常工作

网站公告

今日签到

热门文章

最新发布