Fehlerbehebung bei einem Pub/Sub-Connector

In diesem Abschnitt finden Sie Anleitungen zur Fehlerbehebung bei häufigen Problemen, die bei der Verwendung eines Pub/Sub-Quell-Connectors oder Pub/Sub-Senken-Connectors auftreten.

Fehlende Pub/Sub-Berechtigungen

Wenn das Managed Kafka-Dienstkonto nicht berechtigt ist, auf die Pub/Sub-Ressourcen zuzugreifen, tritt der folgende Fehler auf:

PERMISSION_DENIED: User not authorized to perform this action.

Dieser Fehler kann aus verschiedenen Gründen auftreten.

  • Pub/Sub-Quellconnector: Das Managed Kafka-Dienstkonto hat möglicherweise keine Berechtigung für den Zugriff auf das Pub/Sub-Abo. Um dieses Problem zu beheben, weisen Sie dem Managed Kafka-Dienstkonto die folgenden IAM-Rollen (Identity and Access Management) zu:

    • Pub/Sub-Abonnent (roles/pubsub.subscriber)
    • Pub/Sub-Betrachter (roles/pubsub.viewer)

    Weitere Informationen finden Sie unter Berechtigungen zum Lesen aus dem Pub/Sub-Abo erteilen.

  • Pub/Sub-Senken-Connector: Das Managed Kafka-Dienstkonto hat möglicherweise keine Berechtigung zum Veröffentlichen im Pub/Sub-Thema. Um dieses Problem zu beheben, weisen Sie dem Managed Kafka-Dienst die IAM-Rolle Pub/Sub-Publisher (roles/pubsub.publisher) zu.

    Weitere Informationen finden Sie unter Berechtigungen zum Veröffentlichen im Pub/Sub-Thema erteilen.

Fehler beim Bestätigen des Abos

Wenn der Pub/Sub-Quell-Connector das Pub/Sub-Abo nicht finden kann, schlägt der Connector mit einem Fehler ähnlich dem folgenden fehl:

org.apache.kafka.connect.errors.ConnectException: Error verifying the subscription SUBSCRIPTION for project PROJECT

Prüfen Sie zur Behebung dieses Problems, ob in der cps.subscription-Konfiguration des Connectors das richtige Abo angegeben ist und ob das Abo in Ihrem Projekt vorhanden ist.

Connector-Aufgaben konnten keine Datensätze konvertieren

Wenn der Schlüssel- oder Wertkonverter des Connectors nicht mit dem Datentyp der Datensätze kompatibel ist, schlägt der Connector mit einem Fehler ähnlich dem folgenden fehl:

org.apache.kafka.connect.errors.DataException: Invalid schema type for
CONVERTER_NAME: DATA_FORMAT

Um dieses Problem zu beheben, ändern Sie den Schlüssel- oder Wertkonverter in die richtige Klasse, um den Schemadatentyp zu unterstützen.

Wenn Sie den Schlüsselkonverter beispielsweise auf ByteArrayConverter festlegen, wird möglicherweise der Fehler "Invalid schema type for ByteArrayConverter: STRING" angezeigt. Dieser Fehler tritt auf, weil ByteArrayConverter keine STRING-Typen unterstützt. Verwenden Sie stattdessen org.apache.kafka.connect.storage.StringConverter.

Nächste Schritte