24.4 Installieren und Konfigurieren von Kafka Connect und Adobe Experience Platform Sink Connector

24.4.1 Adobe Experience Platform Sink Connector herunterladen

Gehen Sie zu https://github.com/adobe/experience-platform-streaming-connect/releases und laden Sie die neueste offizielle Version des Adobe Experience Platform Sink Connectors herunter.

Platzieren Sie die Download-Datei streaming-connect-sink-0.0.6-java-11.jar auf Ihrem Desktop.

24.4.2 Kafka Connect konfigurieren

Wechseln Sie zum Ordner auf Ihrem Desktop mit dem Namen Kafka_AEP und navigieren Sie zum Ordner kafka_2.13-2.8.0/config.
Öffnen Sie in diesem Ordner die Datei connect-distributed.properties mit einem beliebigen Texteditor.

Navigieren Sie in Ihrem Texteditor zu den Zeilen 34 und 35 und stellen Sie sicher, dass die Felder key.converter.schemas.enable und value.converter.schemas.enable auf false eingestellt sind.

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

Gehen Sie dann zurück zum Ordner kafka_2.13-2.8.0 und erstellen Sie manuell einen neuen Ordner und nennen Sie ihn connectors.

Klicken Sie mit der rechten Maustaste auf den Ordner und klicken Sie auf Neues Terminal unter Ordner.

Dann wirst du das sehen. Geben Sie den Befehl pwd ein, um den vollständigen Pfad für diesen Ordner abzurufen. Wählen Sie den vollständigen Pfad aus und kopieren Sie ihn in die Zwischenablage.

Gehen Sie zurück zum Texteditor, wechseln Sie zur Datei connect-distributed.properties und scrollen Sie zur letzten Zeile (Zeile 86 im Screenshot). Sie sollten die Auskommentierung der mit # plugin.path= beginnenden Zeile aufheben und den vollständigen Pfad zum Ordner connectors einfügen. Das Ergebnis sollte in etwa wie folgt aussehen:

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

Speichern Sie Ihre Änderungen in der Datei connect-distributed.properties und schließen Sie den Texteditor.

Kopieren Sie dann die neueste offizielle Version des Adobe Experience Platform Sink Connectors, den Sie in den Ordner connectors heruntergeladen haben. Die zuvor heruntergeladene Datei heißt streaming-connect-sink-0.0.6-java-11.jar. Sie können sie einfach in den Ordner connectors verschieben.

Als Nächstes öffnen Sie ein neues Terminal-Fenster auf der Ebene des Ordners kafka_2.13-2.8.0. Klicken Sie mit der rechten Maustaste auf diesen Ordner und klicken Sie auf Neues Terminal unter Ordner.

Fügen Sie im Terminal-Fenster diesen Befehl ein: bin/connect-distributed.sh config/connect-distributed.properties und klicken Sie auf Enter. Mit diesem Befehl wird Kafka Connect gestartet und die Bibliothek des Adobe Experience Platform Sink Connectors geladen.

Nach ein paar Sekunden sehen Sie etwas wie Folgendes:

24.4.3 Erstellen Sie Ihren Adobe Experience Platform Sink-Connector mit Postman

Sie können jetzt mit Kafka Connect über Postman interagieren. Laden Sie dazu diese Postman-Sammlung herunter und entpacken Sie sie auf Ihren lokalen Computer auf dem Desktop. Sie haben dann eine Datei, die Kafka_AEP.postman_collection.json heißt.

Sie müssen diese Datei in Postman importieren. Öffnen Sie dazu Postman, klicken Sie auf Import, ziehen Sie die Datei Kafka_AEP.postman_collection.json per Drag-and-Drop in das Popup-Fenster und klicken Sie auf Import.

Sie finden diese Kollektion dann im linken Menü von Postman. Klicken Sie auf die erste Anforderung GET Verfügbare Kafka Connect-Connectoren , um sie zu öffnen.

Dann wirst du das sehen. Klicken Sie auf die blaue Schaltfläche Senden, danach sollte eine leere Antwort [] angezeigt werden. Die leere Antwort ist darauf zurückzuführen, dass derzeit keine Kafka Connect-Connectoren definiert sind.

Um einen Connector zu erstellen, klicken Sie auf , um die zweite Anforderung in der Kafka-Sammlung zu öffnen, POST AEP Sink Connector erstellen. Dann wirst du das sehen. In Zeile 11, wo "aep.endpoint" steht: ", müssen Sie die HTTP-API-Streaming-Endpunkt-URL, die Sie am Ende der Übung erhalten haben, einfügen 24.3. Die URL des HTTP-API-Streaming-Endpunkts sieht wie folgt aus: https://dcs.adobedc.net/collection/94981e0634e0d37c3559ce7ece05a35eae35c52cc5962d2d4a44e488400f2338.

Nach dem Einfügen sollte der Hauptteil Ihrer Anforderung wie folgt aussehen: Klicken Sie auf die blaue Schaltfläche Senden , um Ihren Connector zu erstellen. Sie erhalten eine sofortige Antwort von der Erstellung Ihres Connectors.

Klicken Sie auf die erste Anforderung GET Verfügbare Kafka Connect-Connectoren , um sie erneut zu öffnen, und klicken Sie erneut auf die blaue Schaltfläche Senden . Sie werden sehen, dass ein Kafka Connect-Connector erstellt wurde.

Öffnen Sie als Nächstes die dritte Anforderung in der Kafka-Sammlung GET Check Kafka Connect Connector Status. Klicken Sie auf die blaue Schaltfläche Senden. Daraufhin erhalten Sie eine Antwort wie die unten stehende, in der erklärt wird, dass der Connector ausgeführt wird.

24.4.4 Ereignis erstellen

Öffnen Sie ein neues Fenster Terminal, indem Sie mit der rechten Maustaste auf den Ordner kafka_2.13-2.8.0 klicken und Neues Terminal unter Ordner klicken.

Geben Sie den folgenden Befehl ein:

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

Dann wirst du das sehen. Jede neue Zeile, gefolgt von der Enter-Schaltfläche, sendet eine neue Nachricht an das Thema aep.

Jetzt können Sie eine Nachricht senden, die vom Adobe Experience Platform Sink Connector genutzt wird und in Echtzeit in Adobe Experience Platform aufgenommen wird.

Lass uns ein kleines Demo machen, um das zu testen.

Öffnen Sie ein neues, sauberes Inkognito-Browser-Fenster und gehen Sie zu https://public.aepdemo.net.

Dann wirst du das sehen.

Geben Sie Ihre Konfigurations-ID ein und klicken Sie auf Konfiguration laden. Ihre Konfiguration wird dann geladen.

Scrollen Sie nach unten und klicken Sie auf Konfiguration speichern.

Sie werden dann zur Admin-Homepage weitergeleitet. Gehen Sie zu Wählen Sie LDAP. Wählen Sie Ihren LDAP aus und klicken Sie auf Save.

Sie werden dann zur Admin-Homepage weitergeleitet. Gehen Sie zu Wählen Sie Marke und wählen Sie die Marke Luma aus. Klicken Sie auf Speichern.

Sie werden dann zur Admin-Homepage weitergeleitet. Klicken Sie auf das Logo Luma.

Dann sehen Sie die Startseite von Luma.

Gehen Sie zu Anmelden/Registrieren. Füllen Sie das Formular aus und klicken Sie auf Konto erstellen. Vergessen Sie nicht, das Kontrollkästchen für Testprofil zu aktivieren.

Anschließend werden Ihre Profildaten im Röntgenfenster angezeigt.

Sie werden auch sehen, dass noch keine Erlebnisereignisse aufgezeichnet wurden.

Ändern wir das und senden ein Callcenter-Erlebnisereignis von Kafka nach Adobe Experience Platform.

Nehmen Sie die folgende Beispielnutzlast für Erlebnisereignisse und kopieren Sie sie in einen Texteditor.

{
  "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"
            }
          }
        }
      }
    }
  }
}

Dann wirst du das sehen. Sie müssen zwei Felder manuell aktualisieren:

• _id: Legen Sie sie bitte auf Ihren ldap fest, gefolgt von einer zufälligen Ziffernfolge, z. B.: vangeluw1234
• phoneNumber: Geben Sie die phoneNumber des Kontos ein, das gerade auf der Demowebsite erstellt wurde. Sie finden sie im Röntgen-Bedienfeld unter Identitäten.

Sie sollten dann etwas wie Folgendes haben:

Kopieren Sie dann Ihr gesamtes Erlebnisereignis in die Zwischenablage. Der Leerraum Ihrer JSON-Payload muss entfernt werden. Dazu verwenden wir ein Online-Tool. Gehen Sie dazu zu http://jsonviewer.stack.hu/.

Fügen Sie Ihr Erlebnisereignis in den Editor ein und klicken Sie auf Leerraum entfernen.

Wählen Sie anschließend den gesamten Ausgabetext aus und kopieren Sie ihn in die Zwischenablage.

Kehren Sie zu Ihrem Terminal-Fenster zurück.

Fügen Sie die neue Payload ohne Leerzeichen in das Terminal-Fenster ein und klicken Sie auf Enter.

Gehen Sie anschließend zurück zu Ihrer Demo-Website und aktualisieren Sie die Seite. Es sollte nun ein Erlebnisereignis in Ihrem Profil unter Andere Ereignisse angezeigt werden, wie im folgenden Beispiel:

Du hast diese Übung beendet.

Nächster Schritt: Zusammenfassung und Vorteile

Zurück zu Modul 24

Zu allen Modulen zurückkehren