Apache Kafka-Connector in Jitterbit Studio

Zusammenfassung

Der Apache Kafka-Connector stellt Zugriff auf Apache Kafka bereit.

Der Apache Kafka-Connector bietet eine Schnittstelle zum Erstellen einer Apache Kafka-Verbindung, die Grundlage für die Generierung von Instanzen von Apache Kafka-Aktivitäten. Diese Aktivitäten interagieren nach der Konfiguration mit Apache Kafka über die Verbindung.

Der Apache Kafka-Connector wird über die Registerkarte Project endpoints and connectors (Projekt-Endpunkte und Connectoren) der Palette der Designkomponenten aufgerufen (siehe Design component palette).

Connector-Übersicht

Dieser Connector dient zunächst zum Konfigurieren einer Apache Kafka-Verbindung. Die mit dieser Verbindung verknüpften Aktivitätstypen werden dann verwendet, um Instanzen von Aktivitäten zu erstellen, die als Quellen (zum Bereitstellen von Daten in einem Vorgang) oder Ziele (zum Verarbeiten von Daten in einem Vorgang) verwendet werden sollen.

Zusammen werden eine bestimmte Apache Kafka-Verbindung und ihre Aktivitäten als Apache Kafka-Endpunkt bezeichnet:

• Send Message: Sendet Datenströme in ein Topic in einem Apache Kafka-Cluster und ist als Ziel in einem Vorgang vorgesehen.

• Get Messages: Ruft Datenströme aus einem Topic in einem Apache Kafka-Cluster ab und ist als Quelle in einem Vorgang vorgesehen.

Mit diesem Connector erstellte Endpunkte werden in die Endpunkt-Nutzungsberichte einbezogen und werden auf die Lizenz angerechnet.

Voraussetzungen und unterstützte API-Versionen

Dieser Connector kann mit Cloud-Agenten und privaten Agenten verwendet werden.

Agenten laden automatisch die neueste Version dieses Connectors herunter, wenn erforderlich. Bei privaten Agenten können diese Updates mit der Organisationsrichtlinie Disable Auto Connector Update ausgesetzt werden.

Der Apache Kafka-Connector verwendet die Apache Kafka Core API. Informationen zu den Schema-Knoten und Feldern finden Sie in der API-Dokumentation.

Fehlerbehebung

Bei Problemen mit dem Apache Kafka-Connector werden folgende Schritte zur Fehlerbehebung empfohlen:

1. Klicken Sie auf die Schaltfläche Test in der Verbindungskonfiguration, um sicherzustellen, dass die Verbindung erfolgreich ist und die neueste Version des Connectors auf den Agent heruntergeladen wird (sofern nicht die Organisationsrichtlinie Disable Auto Connector Update verwendet wird).

2. Überprüfen Sie die Vorgangsprotokolle auf Informationen, die während der Ausführung des Vorgangs geschrieben wurden.

3. Aktivieren Sie das Debug-Protokollieren für Vorgänge (für Cloud-Agenten oder für private Agenten), um zusätzliche Protokolldateien und Daten zu generieren.

4. Bei Verwendung von privaten Agenten können Sie das ausführliche Protokollieren für Connectoren für diesen Connector aktivieren, indem Sie diesen Logger-Konfigurationseintrag in die logback.xml-Datei des privaten Agenten einfügen:

   <logger name="org.jitterbit.connector.apache.kafka" level="DEBUG"/>
   

   Weitere Informationen zum ausführlichen Protokollieren für Connectoren finden Sie unter Verbose logging for connectors using Jitterbit private agents.

5. Bei Verwendung von privaten Agenten können Sie die Agent-Protokolle auf weitere Informationen überprüfen.

6. Weitere Überlegungen zur Fehlerbehebung finden Sie unter Fehlerbehebung bei Operationen.