Apache Kafka-Konnektor für Jitterbit Integration Studio
Zusammenfassung
Der Apache Kafka Konnektor stellt den Zugriff auf Apache Kafka her.
Der Apache Kafka Konnektor bietet eine Schnittstelle zum Erstellen einer Apache Kafka-Verbindung, die die Grundlage für die Generierung von Instanzen von Apache Kafka-Aktivitäten bildet. Nach der Konfiguration interagieren diese Aktivitäten über die Verbindung mit Apache Kafka.
Der Zugriff auf den Apache Kafka Konnektor erfolgt über die Tab Endpoints und -konnektoren der Designkomponentenpalette (siehe Komponentenpalette).
Connector-Übersicht
Dieser Connector wird verwendet, um zunächst eine Apache Kafka Verbindung zu konfigurieren. Mit dieser Verbindung verknüpfte Aktivitätstypen werden dann verwendet, um Instanzen von Aktivitäten zu erstellen, die als Quellen (zum Bereitstellen von Daten in einer Operation) oder Ziele (zum Verbrauchen von Daten in einer Operation) verwendet werden sollen.
Zusammen werden eine bestimmte Apache Kafka Verbindung und ihre Aktivitäten als Apache Kafka Endpoint bezeichnet:
-
Nachricht senden: Sendet Datenströme in ein Thema in einem Apache Kafka Cluster und soll als Ziel bei einer Operation verwendet werden.
-
Nachrichten abrufen: Ruft Datenströme aus einem Thema ab in einem Apache Kafka Cluster und ist für die Verwendung als Quelle in einer Operation vorgesehen.
Hinweis
Dieser Konnektor ist ein Konnektor-SDK-basierter Konnektor, auf den Jitterbit bei der Kommunikation von Änderungen an mit dem Connector SDK erstellten Konnektoren verweisen kann.
Voraussetzungen und unterstützte API Versionen
Der Apache Kafka Connector erfordert die Verwendung eines Agenten der Version 10.1 oder höher. Diese Agent-Versionen laden bei Bedarf automatisch die neueste Version des Connectors herunter.
Der Apache Kafka-Konnektor verwendet die Apache Kafka Core API. Informationen zu den Schema und -feldern finden Sie in der API Dokumentation.
Fehlerbehebung
Wenn Probleme mit dem Apache Kafka Connector auftreten, werden die folgenden Schritte zur Fehlerbehebung empfohlen:
-
Klicken Sie in der Verbindungskonfiguration auf die Schaltfläche Test, um sicherzustellen, dass die Verbindung erfolgreich ist und die neueste Version des Connectors auf den Agenten heruntergeladen wird (es sei denn, Sie verwenden die Organisationsrichtlinie Automatische Connector-Aktualisierung deaktivieren).
-
Überprüfen Sie die Operation für alle Informationen, die während der Ausführung der Operation geschrieben werden.
-
Aktivieren Sie die debuggen Protokollierung für Operation (für Cloud-Agenten oder für private Vertreter), um zusätzliche Protokolldateien und Daten zu generieren.
-
Bei Verwendung privater Agenten können Sie die ausführliche Protokollierung des Connectors aktivieren für diesen Connector unter Verwendung des folgenden Konfigurationseintrags für Loggername und -ebene:
<logger name="org.jitterbit.connector.apache.kafka" level="DEBUG"/>
-
Wenn Sie private Agenten verwenden, können Sie die Agentenprotokolle überprüfen für weitere Informationen.
-
Weitere Hinweise zur Fehlerbehebung finden Sie unter Fehlerbehebung im Betrieb.