Hinzufügen der Apache Kafka-Quelle zu einem Fabric-Eventstream (Vorschau)

In diesem Artikel wird gezeigt, wie Sie eine Apache Kafka-Quelle zu einem Fabric-Ereignisstream hinzufügen.

Apache Kafka ist eine verteilte Open-Source-Plattform zum Erstellen skalierbarer Systeme mit Echtzeitdaten. Durch die Integration von Apache Kafka als Quelle in Ihren Eventstream können Sie die Echtzeitereignisse von Apache Kafka nahtlos übertragen und verarbeiten, bevor Sie sie an mehrere Ziele innerhalb von Fabric weiterleiten.

Voraussetzungen

• Erhalten Sie Zugriff auf einen Fabric-Arbeitsbereich mit Mitwirkender-Berechtigungen oder höher.
• Ein Apache Kafka-Cluster wird ausgeführt.
• Ihr Apache Kafka muss öffentlich zugänglich sein und darf sich nicht hinter einer Firewall oder in einem virtuellen Netzwerk befinden. 

Apache Kafka als Quelle hinzufügen

1. In Fabric Echtzeitintelligenz wählen Sie Eventstream aus, um einen neuen Eventstream zu erstellen.

   

2. Wählen Sie auf der nächsten Anzeige Externe Quelle hinzufügen aus.

   

3. Wählen Sie auf der Seite "Datenquelle auswählen" oder "Datenquellen" die Option Apache Kafka aus.

   

Konfigurieren und Herstellen einer Verbindung mit Apache Kafka

1. Wählen Sie auf der Seite Verbinden die Option Neue Verbindung aus.

   

2. Geben Sie im Abschnitt Verbindungseinstellungen für Bootstrap-ServerIhre Apache Kafka-Serveradresse ein.

   

3. Wählen Sie im Abschnitt "Verbindungsanmeldeinformationen " eine vorhandene Verbindung mit dem Apache Kafka-Cluster aus der Dropdownliste für "Connection" aus. Führen Sie andernfalls die folgenden Schritte aus:

   1. Geben Sie für Verbindungsname einen Namen für die Verbindung ein.
   2. Vergewissern Sie sich bei der Authentifizierungsart, dass der API-Schlüssel ausgewählt ist.
   3. Geben Sie für Schlüssel und geheimen Schlüsselden API-Schlüssel und den Schlüsselschlüsselschlüssel ein.

4. Wählen Sie Verbinden. 

5. Führen Sie nun auf der Seite Verbinden die folgenden Schritte aus.

   1. Geben Sie für Thema das Thema Kafka ein.

   2. Geben Sie für Verbrauchergruppe die Verbrauchergruppe Ihres Apache Kafka-Clusters ein. Dieses Feld bietet Ihnen eine dedizierte Verbrauchergruppe zum Abrufen von Ereignissen.

   3. Wählen Sie den automatischen Offset zurücksetzen aus, um anzugeben, wo leseversatz gestartet werden soll, wenn kein Commit vorhanden ist.

   4. Für neu hinzugefügte Apache Kafka-Quellen wird das einzige unterstützte SicherheitsprotokollSASL_SSL. Bei Verwendung von SASL_SSL muss das Serverzertifikat von einer Zertifizierungsstelle signiert werden, die in der Liste der vertrauenswürdigen Zertifizierungsstellen enthalten ist.

   5. Der STANDARDMÄßIGe SASL-Mechanismus ist in der Regel PLAIN, sofern nicht anders konfiguriert. Sie können den SCRAM-SHA-256 - oder SCRAM-SHA-512-Mechanismus auswählen, der Ihren Sicherheitsanforderungen entspricht.

      

6. Wählen Sie Weiter aus. Überprüfen Sie auf der Anzeige Überprüfen und Erstellen die Zusammenfassung, und wählen Sie dann Hinzufügen aus.

Anzeigen des aktualisierten Eventstreams

Sie können die Apache Kafka-Quelle sehen, die Ihrem Eventstream im Bearbeitungsmodushinzugefügt wurde. 

Nachdem Sie diese Schritte ausgeführt haben, ist die Apache Kafka-Quelle für die Visualisierung in der Liveansichtverfügbar.

Zugehöriger Inhalt

Andere Connectors:

• Amazon Kinesis Data Streams
• Azure Cosmos DB
• Azure Event Hubs
• Azure IoT Hub
• Azure SQL Datenbank Change Data Capture (CDC)
• Benutzerdefinierter Endpunkt
• Google Cloud Pub/Sub
• MySQL Datenbank CDC
• PostgreSQL Datenbank CDC
• Beispieldaten
• Azure Blob Storage Events
• Fabric Arbeitsbereich-Event