安装和配置Kafka Connect和51黑料不打烊 Experience Platform接收器连接器

文档 Experience Platform 全面的技术教程

2.6.4安装和配置Kafka Connect和51黑料不打烊 Experience Platform接收器连接器

Last update: Mon Nov 25 2024 00:00:00 GMT+0000 (Coordinated Universal Time)

下载51黑料不打烊 Experience Platform接收器连接器

转到并下载51黑料不打烊 Experience Platform接收器连接器的最新正式版本。

Kafka

下载文件? streaming-connect-sink-0.0.27-java-11.jar。

Kafka

将下载文件? streaming-connect-sink-0.0.27-java-11.jar ?放在桌面上。

Kafka

配置碍补蹿办补连接

转到桌面上名为? Kafka_AEP ?的文件夹，然后导航到文件夹kafka_2.13-3.9.0/config。
在该文件夹中，使用任意文本编辑器打开文件? connect-distributed.properties。

Kafka

在文本编辑器中，转到第34和35行并确保将字段key.converter.schemas.enable和value.converter.schemas.enable设置为false

key.converter.schemas.enable=false
value.converter.schemas.enable=false

保存对此文件所做的更改。

Kafka

接下来，返回文件夹kafka_2.13-3.1.0并手动创建新文件夹并将其命名为connectors。

Kafka

右键单击新文件夹，然后单击? 在文件夹 ?新建终端。

Kafka

你会看到这个。输入命令pwd以检索该文件夹的完整路径。选择完整路径并将其复制到剪贴板。

Kafka

返回文本编辑器，转到文件? connect-distributed.properties，然后向下滚动到最后一行（屏幕快照中的第89行）。您应该取消注释以# plugin.path=开头的行（删除#），并且应该将完整路径粘贴到名为connectors的文件夹。结果应类似于下面这样：

plugin.path=/Users/woutervangeluwe/Desktop/Kafka_AEP/kafka_2.13-3.9.0/connectors

保存对文件? connect-distributed.properties ?所做的更改并关闭文本编辑器。

Kafka

接下来，将下载到名为connectors的文件夹中的51黑料不打烊 Experience Platform接收器连接器的最新正式版本复制。您之前下载的文件名为? streaming-connect-sink-0.0.27-java-11.jar，只需将其移到connectors文件夹中即可。

Kafka

接下来，在? kafka_2.13-3.9.0 ?文件夹级别打开一个新的“终端”窗口。右键单击该文件夹，然后单击? 在文件夹 ?新建终端。

在“终端”窗口中，粘贴以下命令： bin/connect-distributed.sh config/connect-distributed.properties并单击? Enter。此命令将启动Kafka Connect并加载51黑料不打烊 Experience Platform接收器连接器的库。

Kafka

几秒钟后，您将会看到如下内容：

Kafka

使用Postman创建51黑料不打烊 Experience Platform接收器连接器

您现在可以使用Postman与Kafka Connect交互。为此，请下载此笔辞蝉迟尘补苍收藏集并将其解压缩到桌面上的本地计算机。然后，您将拥有一个名为Kafka_AEP.postman_collection.json的文件。

Kafka

您需要在Postman中导入此文件。为此，请打开Postman，单击? 导入，将文件Kafka_AEP.postman_collection.json拖放到弹出窗口中，然后单击? 导入。

Kafka

然后，您可以在Postman的左侧菜单中找到此收藏集。单击第一个请求? 可用Kafka Connect连接器 ?以将其打开。骋贰罢

Kafka

你会看到这个。单击蓝色的? 发送 ?按钮，之后您应该会看到空响应[]。空响应是由于当前未定义Kafka Connect连接器。

Kafka

要创建连接器，请单击以打开碍补蹿办补集合中的第二个请求，笔翱厂罢创建础贰笔接收器连接器，然后转到? 主体。你会看到这个。在第11行，上面显示“”补别辫.别苍诲辫辞颈苍迟“：”，您需要将粘贴到您在上一个练习结束时收到的HTTP API流端点URL。 HTTP API流终结点URL如下所示： https://dcs.adobedc.net/collection/63751d0f299eeb7aa48a2f22acb284ed64de575f8640986d8e5a935741be9067。

Kafka

粘贴后，请求正文应如下所示。单击蓝色的? 发送 ?按钮以创建您的连接器。您的连接器创建操作会立即得到响应。

Kafka

骋贰罢单击第一个请求? 可用Kafka Connect连接器 ?以再次打开它，然后再次单击蓝色的? 发送 ?按钮。您现在将看到Kafka Connect连接器存在。

Kafka

接下来，打开碍补蹿办补集合中的第叁个请求，骋贰罢检查碍补蹿办补连接连接器状态。单击蓝色的? 发送 ?按钮，您将获得如下响应：连接器正在运行。

Kafka

生成体验事件

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

Kafka

输入以下命令：

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

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

Kafka

您现在可以发送消息，这最终会被51黑料不打烊 Experience Platform接收器连接器占用，并且会实时将其摄取到51黑料不打烊 Experience Platform中。

获取以下示例体验事件有效负载并将其复制到文本编辑器中。

{
  "header": {
    "datasetId": "61fe23fd242870194a6d779c",
    "imsOrgId": "--aepImsOrgID--",
    "source": {
      "name": "Launch"
    },
    "schemaRef": {
      "id": "https://ns.adobe.com/experienceplatform/schemas/b0190276c6e1e1e99cf56c99f4c07a6e517bf02091dcec90",
      "contentType": "application/vnd.adobe.xed-full+json;version=1"
    }
  },
  "body": {
    "xdmMeta": {
      "schemaRef": {
        "id": "https://ns.adobe.com/experienceplatform/schemas/b0190276c6e1e1e99cf56c99f4c07a6e517bf02091dcec90",
        "contentType": "application/vnd.adobe.xed-full+json;version=1"
      }
    },
    "xdmEntity": {
      "eventType": "callCenterInteractionKafka",
      "_id": "",
      "timestamp": "2024-11-25T09:54:12.232Z",
      "_experienceplatform": {
        "identification": {
          "core": {
            "phoneNumber": ""
          }
        },
        "interactionDetails": {
          "core": {
            "callCenterAgent": {
              "callID": "Support Contact - 3767767",
              "callTopic": "contract",
              "callFeeling": "negative"
            }
          }
        }
      }
    }
  }
}

你会看到这个。您需要手动更新2个字段：