2.6.4安裝並設定Kafka Connect和Adobe Experience Platform接收器聯結器

Last update: Mon May 05 2025 00:00:00 GMT+0000 (Coordinated Universal Time)

下載Adobe Experience Platform接收器聯結器

移至https://github.com/adobe/experience-platform-streaming-connect/releases並下載Adobe Experience Platform接收器聯結器的最新正式版本。

Kafka

下載檔案 streaming-connect-sink-0.0.27-java-11.jar。

Kafka

將下載檔案 streaming-connect-sink-0.0.27-java-11.jar 放到您的案頭上。

Kafka

設定Kafka Connect

移至案頭上名為 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的資料夾的最新正式Adobe 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並載入Adobe Experience Platform接收器聯結器的程式庫。

Kafka

幾秒後，您會看到類似以下畫面：

Kafka

使用Postman建立Adobe Experience Platform接收器聯結器

您現在可以使用Postman與Kafka Connect互動。若要這樣做，請下載此Postman集合，並將其解壓縮至案頭上的本機電腦。然後，您會擁有名為Kafka_AEP.postman_collection.json的檔案。

Kafka

您需要在Postman中匯入此檔案。若要這麼做，請開啟Postman，按一下匯入，將檔案Kafka_AEP.postman_collection.json拖放到快顯視窗中，然後按一下匯入。

Kafka

之後，您會在Postman的左側功能表中找到此集合。按一下第一個要求 GET Available Kafka Connect聯結器 以開啟它。

Kafka

您將會看到此訊息。按一下藍色的傳送按鈕，之後您應該會看到空白回應[]。空白回應是因為目前未定義任何Kafka Connect聯結器。

Kafka

若要建立聯結器，請按一下以開啟Kafka集合中的第二個要求，POST建立AEP接收器聯結器，並移至內文。您將會看到此訊息。在第11行，上面顯示 "aep.endpoint"："，您需要貼入您在前一個練習結束時收到的HTTP API串流端點URL。 HTTP API串流端點URL看起來像這樣： https://dcs.adobedc.net/collection/63751d0f299eeb7aa48a2f22acb284ed64de575f8640986d8e5a935741be9067。

Kafka

貼上要求後，其內文看起來應該像這樣。按一下藍色的傳送按鈕以建立您的聯結器。建立聯結器後，您會立即收到回應。

Kafka

按一下第一個要求 GET Available Kafka Connect connectors，再次開啟該要求，然後按一下藍色的傳送按鈕。您現在會看到Kafka Connect聯結器存在。

Kafka

接著，開啟Kafka集合中的第三個要求 GET Check Kafka Connect Connector Status。按一下藍色的傳送按鈕，您將會收到如下所示的回應，表示聯結器正在執行。

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

您現在可以傳送訊息，訊息會由Adobe Experience Platform接收器聯結器使用，並即時擷取到Adobe 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個欄位：