Risolvere i problemi relativi a un connettore Pub/Sub

Questa sezione fornisce indicazioni per la risoluzione dei problemi comuni riscontrati quando si utilizza un connettore di origine Pub/Sub o un connettore di sink Pub/Sub.

Autorizzazioni Pub/Sub mancanti

Se il account di servizio Kafka gestito non dispone dell'autorizzazione per accedere alle risorse Pub/Sub, si verifica il seguente errore:

PERMISSION_DENIED: User not authorized to perform this action.

Questo errore può verificarsi per diversi motivi.

  • Connettore di origine Pub/Sub: il account di servizio Kafka gestito potrebbe non disporre dell'autorizzazione per accedere alla sottoscrizione Pub/Sub. Per risolvere il problema, concedi al account di servizio gestito Kafka entrambi i seguenti ruoli IAM (Identity and Access Management):

    • Pub/Sub Subscriber (roles/pubsub.subscriber)
    • Visualizzatore Pub/Sub (roles/pubsub.viewer)

    Per maggiori informazioni, vedi Concedere le autorizzazioni per la lettura dalla sottoscrizione Pub/Sub.

  • Connettore di sink Pub/Sub: il account di servizio Managed Kafka potrebbe non disporre dell'autorizzazione per pubblicare nell'argomento Pub/Sub. Per risolvere il problema, concedi al servizio Managed Kafka il ruolo IAM Pub/Sub Publisher (roles/pubsub.publisher).

    Per maggiori informazioni, consulta Concedere le autorizzazioni per la pubblicazione nell'argomento Pub/Sub.

Errore durante la verifica dell'abbonamento

Se il connettore di origine Pub/Sub non riesce a trovare la sottoscrizione Pub/Sub, il connettore non funziona e viene visualizzato un errore simile al seguente:

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

Per risolvere il problema, verifica che la configurazione del connettore cps.subscription specifiche l'abbonamento corretto e che l'abbonamento esista nel tuo progetto.

Impossibile convertire i record delle attività del connettore

Se il convertitore di chiavi o il convertitore di valori del connettore non è compatibile con il tipo di dati dei record, il connettore genera un errore simile al seguente:

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

Per risolvere il problema, modifica il convertitore di chiavi o il convertitore di valori con la classe corretta per supportare il tipo di dati dello schema.

Ad esempio, se imposti il convertitore di chiavi su ByteArrayConverter, potresti visualizzare l'errore "Invalid schema type for ByteArrayConverter: STRING". Questo errore si verifica perché ByteArrayConverter non supporta i tipi STRING. Utilizza invece org.apache.kafka.connect.storage.StringConverter.

Passaggi successivi