24.4 Installation et configuration de Kafka Connect et du connecteur Adobe Experience Platform Sink

24.4.1 Téléchargement du connecteur Adobe Experience Platform Sink

Accédez à https://github.com/adobe/experience-platform-streaming-connect/releases et téléchargez la dernière version officielle de Adobe Experience Platform Sink Connector.

Kafka

Placez le fichier de téléchargement, streaming-connect-sink-0.0.6-java-11.jar, sur votre bureau.

Kafka

24.4.2 Configuration de Kafka Connect

Accédez au dossier de votre bureau nommé Kafka_AEP et accédez au dossier kafka_2.13-2.8.0/config.
Dans ce dossier, ouvrez le fichier connect-distribué.properties à l’aide de n’importe quel éditeur de texte.

Kafka

Dans votre éditeur de texte, accédez aux lignes 34 et 35 et assurez-vous de définir les champs key.converter.schemas.enable et value.converter.schemas.enable sur false

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

Kafka

Ensuite, revenez au dossier kafka_2.13-2.8.0 et créez manuellement un nouveau dossier et nommez-le connectors.

Kafka

Cliquez avec le bouton droit sur le dossier et cliquez sur Nouveau terminal dans Folder.

Kafka

Vous verrez alors ceci. Saisissez la commande pwd pour récupérer le chemin complet de ce dossier. Sélectionnez le chemin complet et copiez-le dans le presse-papiers.

Kafka

Revenez à votre éditeur de texte, au fichier connect-Distributed.properties et faites défiler l’écran jusqu’à la dernière ligne (ligne 86 dans la capture d’écran). Vous devez annuler la mise en commentaire de la ligne commençant par # plugin.path= et coller le chemin d’accès complet au dossier nommé connectors. Le résultat doit ressembler à ceci :

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

Enregistrez vos modifications dans le fichier connect-distribué.properties et fermez votre éditeur de texte.

Kafka

Copiez ensuite la dernière version officielle du connecteur Adobe Experience Platform Sink que vous avez téléchargé dans le dossier connectors. Le fichier que vous avez téléchargé précédemment est nommé streaming-connect-sink-0.0.6-java-11.jar. Vous pouvez simplement le déplacer dans le dossier connectors.

Kafka

Ouvrez ensuite une nouvelle fenêtre Terminal au niveau du dossier kafka_2.13-2.8.0 . Cliquez avec le bouton droit de la souris sur ce dossier et cliquez sur New Terminal at Folder.

Dans la fenêtre Terminal, collez la commande suivante : bin/connect-distributed.sh config/connect-distributed.properties et cliquez sur Entrée. Cette commande démarre Kafka Connect et charge la bibliothèque de Adobe Experience Platform Sink Connector.

Kafka

Au bout de quelques secondes, vous verrez quelque chose comme ceci :

Kafka

24.4.3 Création de votre connecteur Adobe Experience Platform Sink à l’aide de Postman

Vous pouvez désormais interagir avec Kafka Connect à l’aide de Postman. Pour ce faire, téléchargez cette collection Postman et décompressez-la sur votre ordinateur local sur le bureau. Vous aurez alors un fichier appelé Kafka_AEP.postman_collection.json.

Kafka

Vous devez importer ce fichier dans Postman. Pour ce faire, ouvrez Postman, cliquez sur Importer, faites glisser le fichier Kafka_AEP.postman_collection.json dans la fenêtre contextuelle, puis cliquez sur Importer.

Kafka

Vous trouverez ensuite cette collection dans le menu de gauche de Postman. Cliquez sur la première requête, Connecteurs Kafka Connect disponibles pour l’ouvrir.

Kafka

Vous verrez alors ceci. Cliquez sur le bouton bleu Envoyer, après lequel vous devriez voir une réponse vide []. La réponse vide est due au fait qu’aucun connecteur Kafka Connect n’est actuellement défini.

Kafka

Pour créer un connecteur, cliquez pour ouvrir la seconde requête dans la collection Kafka, POST Créer un connecteur AEP Sink. Vous verrez alors ceci. Sur la ligne 11, où il est écrit "aep.endpoint" : "", vous devez coller dans l’URL du point de terminaison HTTP API Streaming que vous avez reçue à la fin de l’exercice 24.3. L’URL du point de terminaison de diffusion en continu de l’API HTTP ressemble à ceci : https://dcs.adobedc.net/collection/94981e0634e0d37c3559ce7ece05a35eae35c52cc5962d2d4a44e488400f2338.

Kafka

Après l’avoir collé, le corps de votre requête doit ressembler à ceci. Cliquez sur le bouton bleu Envoyer pour créer votre connecteur. Vous obtiendrez une réponse immédiate à la création de votre connecteur.

Kafka

Cliquez sur la première requête, Connecteurs Kafka Connect disponibles pour l’ouvrir à nouveau, puis cliquez de nouveau sur le bouton bleu Envoyer. vous verrez maintenant qu'un connecteur Kafka Connect est créé.

Kafka

Ouvrez ensuite la troisième requête dans la collection Kafka, GET Vérifiez l’état du connecteur Kafka Connect. Cliquez sur le bouton bleu Envoyer. Vous obtiendrez alors une réponse similaire à celle ci-dessous, indiquant que le connecteur est en cours d’exécution.

Kafka

24.4.4 Génération d’un événement d’expérience

Ouvrez une nouvelle fenêtre Terminal en cliquant avec le bouton droit de la souris sur votre dossier kafka_2.13-2.8.0 et en cliquant sur Nouveau terminal dans le dossier.

Kafka

Saisissez la commande suivante :

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

Kafka

Vous verrez alors ceci. Chaque nouvelle ligne suivie d’un bouton Entrée entraîne l’envoi d’un nouveau message dans la rubrique aep.

Kafka

Vous pouvez maintenant envoyer un message qui sera consommé par Adobe Experience Platform Sink Connector et ingéré dans Adobe Experience Platform en temps réel.

Faisons une petite démonstration pour le tester.

Ouvrez une nouvelle fenêtre de navigateur incognito propre et accédez à https://public.aepdemo.net.

Vous verrez alors ceci.

Configuration de Launch

Saisissez votre ID de configuration et cliquez sur Charger la configuration. Votre configuration est ensuite chargée.

Configuration de Launch

Faites défiler l’écran vers le bas et cliquez sur Enregistrer la configuration.

Configuration de Launch

Vous serez ensuite redirigé vers la page d’accueil Admin. Accédez à Sélectionnez LDAP. Sélectionnez votre LDAP et cliquez sur Enregistrer.

Configuration de Launch

Vous serez ensuite redirigé vers la page d’accueil Admin. Accédez à Sélectionner la marque et sélectionnez la marque Luma, cliquez sur Enregistrer.

Configuration de Launch

Vous serez ensuite redirigé vers la page d’accueil Admin. Cliquez sur le logo Luma .

Configuration de Launch

Vous verrez ensuite la page d’accueil de Luma.

Configuration de Launch

Accédez à Connexion/enregistrement. Remplissez le formulaire et cliquez sur Créer un compte. N’oubliez pas de cocher la case Profil de test.

Kafka

Vous verrez ensuite vos données de profil dans le panneau de rayons X.

Kafka

Vous constaterez également qu’aucun événement d’expérience n’a encore été enregistré.

Kafka

Changeons cela et envoyons un événement d’expérience Callcenter de Kafka à Adobe Experience Platform.

Prenez l’exemple de payload d’événement d’expérience ci-dessous et copiez-le dans un éditeur de texte.

{
  "header": {
    "datasetId": "5fd1a9dea30603194baeea43",
    "imsOrgId": "907075E95BF479EC0A495C73@AdobeOrg",
    "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": "2021-08-12T15:04:03.630Z",
      "_experienceplatform": {
        "identification": {
          "core": {
            "phoneNumber": ""
          }
        },
        "interactionDetails": {
          "core": {
            "callCenterAgent": {
              "callID": "Support Contact - 3767767",
              "callTopic": "contract",
              "callFeeling": "negative"
            }
          }
        }
      }
    }
  }
}

Vous verrez alors ceci. Vous devez mettre à jour manuellement 2 champs :

  • _id : définissez-la sur votre ldap, suivi d’une séquence aléatoire de chiffres, par exemple : vangeluw1234
  • phoneNumber : saisissez le numéro de téléphone du compte qui vient d’être créé sur le site web de démonstration. Vous pouvez le trouver dans le panneau des rayons X sous Identités.
REMARQUE

Le champ _id doit être unique pour chaque ingestion de données. Si vous générez plusieurs événements, veillez à mettre à jour le champ _id à chaque fois vers une nouvelle valeur unique.

Kafka

Vous devriez alors avoir quelque chose comme ceci :

Kafka

Copiez ensuite l’événement d’expérience complet dans le presse-papiers. L’espace blanc de votre charge utile JSON doit être supprimé. Pour ce faire, nous utiliserons un outil en ligne. Pour ce faire, rendez-vous sur http://jsonviewer.stack.hu/.

Kafka

Collez l’événement d’expérience dans l’éditeur, puis cliquez sur Supprimer l’espace blanc.

Kafka

Ensuite, sélectionnez tout le texte de sortie et copiez-le dans le presse-papiers.

Kafka

Revenez à la fenêtre de votre terminal.

Kafka

Collez la nouvelle payload sans espaces dans la fenêtre Terminal, puis cliquez sur Entrée.

Kafka

Revenez ensuite à votre site web de démonstration et actualisez la page. Vous devriez maintenant voir un événement d’expérience sur votre profil, sous Autres événements, comme ci-dessous :

Kafka

Vous avez terminé cet exercice.

Étape suivante : Résumé et avantages

Revenir au module 24

Revenir à tous les modules

Sur cette page