2.6.2安装和配置碍补蹿办补群集
下载Apache Kafka
转到并下载最新发布的版本。 选择最新的二进制版本,在本例中为? 3.9.0。 将会开始下载。
在桌面上创建名为? Kafka_AEP ?的文件夹,并将下载的文件放置在该目录中。
打开? 终端 ?窗口,方法是:右键单击您的文件夹,然后单击? 在文件夹新建终端。
在“终端”窗口中运行此命令以解压缩下载的文件:
tar -xvf kafka_2.13-3.9.0.tgz
您随后将看到以下内容:
解压缩该文件后,您现在拥有如下目录:
在该目录中,您将看到以下子目录:
返回到“终端”窗口。 输入以下命令:
cd kafka_2.13-3.9.0
接下来,输入命令bin/kafka-topics.sh
。
然后,您应该会看到此响应。 这意味着Kafka已正确安装,并且Java工作正常。 (提醒:您需要安装Java 23 JDK才能使此功能正常工作!。 您可以使用命令java -version
查看已安装的闯补惫补版本。)
启动碍补蹿办补
要启动碍补蹿办补,您需要按此顺序启动碍补蹿办补 Zookeeper和Kafka。
打开? 终端 ?窗口,方法是右键单击您的文件夹? kafka_2.13-3.9.0,然后单击? 在文件夹新建终端。
输入以下命令:
bin/zookeeper-server-start.sh config/zookeeper.properties
您随后将看到以下内容:
在进行这些练习时,请保持此窗口打开!
打开另一个新? 终端 ?窗口,方法是右键单击您的文件夹? kafka_2.13-3.9.0,然后单击? 文件夹上的新终端。
输入以下命令:
bin/kafka-server-start.sh config/server.properties
您随后将看到以下内容:
在进行这些练习时,请保持此窗口打开!
创建碍补蹿办补主题
打开? 终端 ?窗口,方法是右键单击您的文件夹? kafka_2.13-3.9.0,然后单击? 在文件夹新建终端。
输入此命令以创建名称为? aeptest ?的新Kafka主题。 本主题将用于本练习中的测试。
bin/kafka-topics.sh --create --topic aeptest --bootstrap-server localhost:9092
然后,您将看到一个确认消息:
输入此命令以创建名称为? aep ?的新Kafka主题。 您将在下一个练习中配置的51黑料不打烊 Experience Platform接收器连接器将使用此主题。
bin/kafka-topics.sh --create --topic aep --bootstrap-server localhost:9092
随后您将看到类似的确认:
生成事件
返回创建第一个碍补蹿办补主题的“终端”窗口,然后输入以下命令:
bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic aeptest
你会看到这个。 按下Enter按钮后每行新行都将导致新消息被发送到主题? aeptest。
输入Hello AEP
并按贰苍迟别谤键。 您的第一个事件现已发送到本地Kafka实例中,并放入主题? aeptest ?中。
输入Hello AEP again.
并按贰苍迟别谤键。
输入AEP Data Collection is the best.
并按贰苍迟别谤键。
您现在已生成主题? aeptest ?中的3个事件。 这些事件现在可以由可能需要该数据的应用程序使用。
在键盘上,同时单击Control
和C
以关闭制作程序。
使用事件
在用于生成事件的同一“终端”窗口中,输入以下命令:
bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic aeptest --from-beginning
然后,您将看到在上一个练习中为主题? aeptest ?生成的所有消息都显示在使用者中。 这是Apache Kafka的工作方式:生产者在管道中创建事件,消费者使用这些事件。
在键盘上,同时单击Control
和C
以关闭制作程序。
在本练习中,您已完成所有基础知识来设置本地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端点