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.

Kafka

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

Kafka

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.

Kafka

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
``

Kafka

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.

Kafka

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

Kafka

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.

Kafka

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.

Kafka

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.

Kafka

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.

Kafka

Nach ein paar Sekunden sehen Sie etwas wie Folgendes:

Kafka

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.

Kafka

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.

Kafka

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.

Kafka

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.

Kafka

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.

Kafka

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.

Kafka

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.

Kafka

Ö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.

Kafka

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.

Kafka

Geben Sie den folgenden Befehl ein:

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

Kafka

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

Kafka

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.

Launch-Einrichtung

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

Launch-Einrichtung

Scrollen Sie nach unten und klicken Sie auf Konfiguration speichern.

Launch-Einrichtung

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.

Launch-Einrichtung

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.

Launch-Einrichtung

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

Launch-Einrichtung

Dann sehen Sie die Startseite von Luma.

Launch-Einrichtung

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.

Kafka

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

Kafka

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

Kafka

Ä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.
HINWEIS

Das Feld _id muss für jede Datenerfassung eindeutig sein. Wenn Sie mehrere Ereignisse erzeugen, stellen Sie sicher, dass Sie das Feld _id jedes Mal auf einen neuen eindeutigen Wert aktualisieren.

Kafka

Sie sollten dann etwas wie Folgendes haben:

Kafka

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/.

Kafka

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

Kafka

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

Kafka

Kehren Sie zu Ihrem Terminal-Fenster zurück.

Kafka

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

Kafka

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:

Kafka

Du hast diese Übung beendet.

Nächster Schritt: Zusammenfassung und Vorteile

Zurück zu Modul 24

Zu allen Modulen zurückkehren

Auf dieser Seite