# 15.4 Install and configure Kafka Connect and the Adobe Experience Platform Sink Connector ## 15.4.1 Download the Adobe Experience Platform Sink Connector Go to and download the latest official release of the Adobe Experience Platform Sink Connector. ![Kafka](/files/548ARik9q5P1Q7Cl8lgV) Place the download file, **streaming-connect-sink-0.0.14-java-11.jar**, onto your desktop. ![Kafka](/files/uOOKmrnSGQQxr6NmMcfE) ## 15.4.2 Configure Kafka Connect Go to the folder on your desktop named **Kafka\_AEP** and navigate to the folder `kafka_2.13-3.1.0/config`. In that folder, open the file **connect-distributed.properties** using any Text Editor. ![Kafka](/files/RKn3RcQ5FF8D9HMym2mv) In your Text Editor, go to line 34 and 35 and make sure to set the fields `key.converter.schemas.enable` and `value.converter.schemas.enable` to `false` ```json key.converter.schemas.enable=false value.converter.schemas.enable=false ``` Save your changes to this file. ![Kafka](/files/xvyMqn2CiHbms3vYXyrj) Next, go back to the folder `kafka_2.13-3.1.0` and manually create a new folder, and name it `connectors`. ![Kafka](/files/joqeIzNH16K54cpMgmYa) Right-click the folder and click **New terminal at Folder**. ![Kafka](/files/6yidVkvbQRuH9t68ODv4) You'll then see this. Enter the command `pwd` to retrieve the full path for that folder. Select the full path and copy it to your clipboard. ![Kafka](/files/XGlp9tBuFn3s1E9nSxiY) Go back to your Text Editor, to the file **connect-distributed.properties** and scroll down to the last line (line 86 in the screenshot). You should uncomment the line that starts with `# plugin.path=` and you should paste the full path to the folder named `connectors`. The result should look similar to this: `plugin.path=/Users/woutervangeluwe/Desktop/Kafka_AEP/kafka_2.13-3.1.0/connectors` Save your changes to the file **connect-distributed.properties** and close your Text Editor. ![Kafka](/files/noAQ6tcxfk69Z8oTL8eP) Next, copy the latest official release of the Adobe Experience Platform Sink Connector that you downloaded into the folder named `connectors`. The file that you downloaded before is named **streaming-connect-sink-0.0.14-java-11.jar**, you can simply move it into the `connectors` folder. ![Kafka](/files/FDT7tcDIczqOXCNyynSw) Next, open a new Terminal window at the level of the **kafka\_2.13-3.1.0** folder. Right-click that folder and click **New Terminal at Folder**. In the Terminal window, paste this command: `bin/connect-distributed.sh config/connect-distributed.properties` and click **Enter**. This command will start Kafka Connect and will load the library of the Adobe Experience Platform Sink Connector. ![Kafka](/files/IbzoR8VEQmWcUZrpCZnj) After a couple of seconds, you'll see something like this: ![Kafka](/files/4IyqPr6dVGnmttonofEb) ## 15.4.3 Create your Adobe Experience Platform Sink Connector using Postman You can now interact with Kafka Connect using Postman. To do so, download [this Postman Collection](https://github.com/AdobePartnerTechnicalServices/aep-quickstart-guide/blob/main/assets/postman/postman_kafka.zip) and uncompress it to your local computer on the desktop. You'll then have a file that is called `Kafka_AEP.postman_collection.json`. ![Kafka](/files/Gz3o8C43kF2vtvZW9xPl) You need to import this file in Postman. To do so, open Postman, click **Import**, drag and drop the file `Kafka_AEP.postman_collection.json` into the popup and click **Import**. ![Kafka](/files/R8wToAAIg6pGjCCAyrh8) You'll then find this collection in the left menu of Postman. Click the first request, **GET Available Kafka Connect connectors** to open it. ![Kafka](/files/67ZBxKCmcOdaXafTfWYR) You'll then see this. Click the blue **Send** button, after which you should see an empty response `[]`. The empty response is due to the fact that no Kafka Connect connectors are currently defined. ![Kafka](/files/7ihETT1XsIh0OMniXzkf) To create a connector, click to open the second request in the Kafka collection, **POST Create AEP Sink Connector**. You'll then see this. On line 11, where it says **"aep.endpoint": ""**, you need to paste in the HTTP API Streaming endpoint URL that you received at the end of exercise [15.3](/comprehensive-technical-tutorial-archive/module15/ex3.md). The HTTP API Streaming endpoint URL looks like this: `https://dcs.adobedc.net/collection/d282bbfc8a540321341576275a8d052e9dc4ea80625dd9a5fe5b02397cfd80dc`. ![Kafka](/files/n6VSi18ht1YQheHjviAw) After pasting it, the body of your request should look like this. Click the blue **Send** button to create your connector. You'll get an immediate response of the creation of your connector. ![Kafka](/files/49XGeMQstBqyv2yklFwb) Click the first request, **GET Available Kafka Connect connectors** to open it again and click the blue **Send** button again. you'll now see that a Kafka Connect connector is created. ![Kafka](/files/7Y8bqpIHIbJeoRs6SOGS) Next, open the third request in the Kafka collection, **GET Check Kafka Connect Connector Status**. Click the blue **Send** button, you'll then get a response like the one below, stating that the connector is running. ![Kafka](/files/X6EJ6p832CKJqfJQPWK3) ## 15.4.4 Produce an experience event Open a new **Terminal** window by right-clicking your folder **kafka\_2.13-3.1.0** and clicking **New Terminal at Folder**. ![Kafka](/files/k6TnIpoWp8iLdn0wEgrL) Enter the following command: `bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic aep` ![Kafka](/files/Zn0aU2gQOPHuJvOfJK2h) You'll then see this. Every new line followed by pushing the Enter button will result in a new message being sent into the topic **aep**. ![Kafka](/files/532XWdhSjhmuPhsF7kV3) You can now send a message, which will result in being consumed by the Adobe Experience Platform Sink Connector, and which will be ingested into Adobe Experience Platform in real-time. Let's do a little demo to test this. Go to . After logging in with your Adobe ID, you'll see this. Click your website project to open it. ![DSN](/files/2TzcSZHZ9qjjaR5vTN1T) On the **Screens** page, click **Run**. ![DSN](/files/PMtmhSLdTGfwrVQzX2Xd) You'll then see your demo website open up. Select the URL and copy it to your clipboard. ![DSN](/files/W2n2RRLhlFySgNdfxucc) Open a new incognito browser window. ![DSN](/files/zZEhiofOQTVr8McFoUHf) Paste the URL of your demo website, which you copied in the previous step. You'll then be asked to login using your Adobe ID. ![DSN](/files/cA7f3IDNG2RAUwUQgCT4) Select your account type and complete the login process. ![DSN](/files/7uNFgLBN1WDiFJBdl5mo) You'll then see your website loaded in an incognito browser window. For every demonstration, you'll need to use a fresh, incognito browser window to load your demo website URL. ![DSN](/files/A2EDjBzPVin0IdMO2kKf) Click the Adobe logo icon in the top left corner of your screen to open the Profile Viewer. ![Demo](/files/MjUWm0pzNc2pyjAjShdz) Have a look at the Profile Viewer panel and the Real-time Customer Profile with the **Experience Cloud ID** as the primary identifier for thi currently unknown customer. ![Demo](/files/ZGjkAriMQZRjJGY3caQa) Go to the Register/Login page. Click **CREATE AN ACCOUNT**. ![Demo](/files/ofyMcJaovGe20Pv1fKIu) Fill out your details and click **Register** after which you'll be redirected to the previous page. ![Demo](/files/7SpI3hKGF0AuixWfByLA) Open the Profile Viewer panel and go to Real-time Customer Profile. On the Profile Viewer panel, you should see all of your personal data displayed, like your newly added email and phone identifiers. ![Demo](/files/x3eDKoJBnxtBRkkqQheN) You may see some experience events based on past activity. ![Kafka](/files/8Zjdtvii8MdgJ6n22LQQ) Let's change that and send in a Callcenter experience event from Kafka into Adobe Experience Platform. Take the below sample experience event payload and copy it into a Text Editor. ```json { "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": "2022-02-23T09:54:12.232Z", "_experienceplatform": { "identification": { "core": { "phoneNumber": "" } }, "interactionDetails": { "core": { "callCenterAgent": { "callID": "Support Contact - 3767767", "callTopic": "contract", "callFeeling": "negative" } } } } } } } ``` You'll then see this. You need to manually update 2 fields: * **\_id**: please set it to a random id, something like `--demoProfileLdap--1234` * **timestamp**: update the timestamp to the current date and time * **phoneNumber**: enter the phoneNumber of the account that was just created on the demo website. You can find it on the Profile Viewer panel under **Identities**. You also need to check and maybe update these fields: * **datasetId**: you need to copy the Dataset ID for the dataset Demo System - Event Dataset for Call Center (Global v1.1) * **imsOrgID**: your IMS Org ID is `--aepImsOrgId--` {% hint style="info" %} The field **\_id** needs to be unique for every data ingestion. If you produce multiple events, please make sure that you update the field **\_id** every time to a new, unique value. {% endhint %} ![Kafka](/files/mViwH1aQCaTdL6Ww4Fa2) You should then have something like this: ![Kafka](/files/7SPT8TphApnmvK7YI7LW) Next, copy your full experience event to your clipboard. The whitespace of your JSON payload needs to be stripped and we'll use an online tool to do that. Go to to do that. ![Kafka](/files/tQwX9hXNqj9n8PimPQoG) Paste your experience event into the editor and click **Remove white space**. ![Kafka](/files/sepSPTjjOymArMesrlv7) Next, select all of the output text and copy it to your clipboard. ![Kafka](/files/jjO5IM8ODIYkwNordn6t) Go back to your Terminal window. ![Kafka](/files/532XWdhSjhmuPhsF7kV3) Paste the new payload without whitespaces into the Terminal window and click **Enter**. ![Kafka](/files/6lX1juSXRPhcKdA08RTB) Next, go back to your demo website and refresh the page. You should now see an experience event on your profile, under **Other Events**, just like the one below: ![Kafka](/files/SfOAdHNAzfWSOPwK2QXt) {% hint style="info" %} If you want your call center interactions to appear on the Profile Viewer panel, you need to add the below label and filter in your project on , by going to the tab **Profile Viewer**. {% endhint %} ![Kafka](/files/U0R7THcvtW2hFS2qPG03) You have finished this exercise. --- # Agent Instructions: Querying This Documentation If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question. Perform an HTTP GET request on the current page URL with the `ask` query parameter: ``` GET https://docs.adobesandbox.com/comprehensive-technical-tutorial-archive/module15/ex4.md?ask= ``` The question should be specific, self-contained, and written in natural language. The response will contain a direct answer to the question and relevant excerpts and sources from the documentation. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.