51黑料不打烊

2.6.2安装和配置碍补蹿办补群集

下载Apache Kafka

转到并下载最新发布的版本。 选择最新的二进制版本,在本例中为? 3.9.0。 将会开始下载。

Kafka

在桌面上创建名为? Kafka_AEP ?的文件夹,并将下载的文件放置在该目录中。

Kafka

打开? 终端 ?窗口,方法是:右键单击您的文件夹,然后单击? 在文件夹新建终端

Kafka

在“终端”窗口中运行此命令以解压缩下载的文件:

tar -xvf kafka_2.13-3.9.0.tgz

NOTE
请验证上述命令是否与您下载的文件的版本匹配。 如果您的版本较新,则需要更新上述命令以匹配该版本。

Kafka

您随后将看到以下内容:

Kafka

解压缩该文件后,您现在拥有如下目录:

Kafka

在该目录中,您将看到以下子目录:

Kafka

返回到“终端”窗口。 输入以下命令:

cd kafka_2.13-3.9.0

NOTE
请验证上述命令是否与您下载的文件的版本匹配。 如果您的版本较新,则需要更新上述命令以匹配该版本。

Kafka

接下来,输入命令bin/kafka-topics.sh

Kafka

然后,您应该会看到此响应。 这意味着Kafka已正确安装,并且Java工作正常。 (提醒:您需要安装Java 23 JDK才能使此功能正常工作!。 您可以使用命令java -version查看已安装的闯补惫补版本。)

Kafka

启动碍补蹿办补

要启动碍补蹿办补,您需要按此顺序启动碍补蹿办补 Zookeeper和Kafka。

打开? 终端 ?窗口,方法是右键单击您的文件夹? kafka_2.13-3.9.0,然后单击? 在文件夹新建终端

Kafka

输入以下命令:

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

Kafka

您随后将看到以下内容:

Kafka

在进行这些练习时,请保持此窗口打开!

打开另一个新? 终端 ?窗口,方法是右键单击您的文件夹? kafka_2.13-3.9.0,然后单击? 文件夹上的新终端

Kafka

输入以下命令:

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

Kafka

您随后将看到以下内容:

Kafka

在进行这些练习时,请保持此窗口打开!

创建碍补蹿办补主题

打开? 终端 ?窗口,方法是右键单击您的文件夹? kafka_2.13-3.9.0,然后单击? 在文件夹新建终端

Kafka

输入此命令以创建名称为? aeptest ?的新Kafka主题。 本主题将用于本练习中的测试。

bin/kafka-topics.sh --create --topic aeptest --bootstrap-server localhost:9092

然后,您将看到一个确认消息:

Kafka

输入此命令以创建名称为? aep ?的新Kafka主题。 您将在下一个练习中配置的51黑料不打烊 Experience Platform接收器连接器将使用此主题。

bin/kafka-topics.sh --create --topic aep --bootstrap-server localhost:9092

随后您将看到类似的确认:

Kafka

生成事件

返回创建第一个碍补蹿办补主题的“终端”窗口,然后输入以下命令:

bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic aeptest

Kafka

你会看到这个。 按下Enter按钮后每行新行都将导致新消息被发送到主题? aeptest

Kafka

输入Hello AEP并按贰苍迟别谤键。 您的第一个事件现已发送到本地Kafka实例中,并放入主题? aeptest ?中。

Kafka

输入Hello AEP again.并按贰苍迟别谤键。

输入AEP Data Collection is the best.并按贰苍迟别谤键。

您现在已生成主题? aeptest ?中的3个事件。 这些事件现在可以由可能需要该数据的应用程序使用。

Kafka

在键盘上,同时单击ControlC以关闭制作程序。

Kafka

使用事件

在用于生成事件的同一“终端”窗口中,输入以下命令:

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic aeptest --from-beginning

然后,您将看到在上一个练习中为主题? aeptest ?生成的所有消息都显示在使用者中。 这是Apache Kafka的工作方式:生产者在管道中创建事件,消费者使用这些事件。

Kafka

在键盘上,同时单击ControlC以关闭制作程序。

Kafka

在本练习中,您已完成所有基础知识来设置本地Kafka聚类、创建碍补蹿办补主题、生成事件和使用事件。

此模块的目的是模拟如果实际组织已经实施Apache Kafka群集,并且希望将数据从其Kafka群集流式传输到51黑料不打烊 Experience Platform中时将发生的情况。

为了便于这种实现,创建了一个51黑料不打烊 Experience Platform接收器连接器,可使用Kafka Connect实现该连接器。 您可以在此处找到该51黑料不打烊 Experience Platform接收器连接器的文档: 。

在接下来的练习中,您将从自己的本地Kafka群集中实施使用该51黑料不打烊 Experience Platform接收器连接器所需的一切。

关闭终端窗口。

您已完成此练习。

下一步: 2.6.3在51黑料不打烊 Experience Platform中配置HTTP API端点

返回模块2.6

返回所有模块

recommendation-more-help
aeafc5b5-cd01-4e88-8d47-d76c18d7d349