Pub/Sub コネクタのトラブルシューティング

このセクションでは、Pub/Sub ソースコネクタまたは Pub/Sub シンクコネクタの使用時に発生する一般的な問題のトラブルシューティング ガイダンスを提供します。

Pub/Sub 権限がない

マネージド Kafka サービス アカウントに Pub/Sub リソースへのアクセス権限がない場合、次のエラーが発生します。

PERMISSION_DENIED: User not authorized to perform this action.

このエラーは、いくつかの原因で発生する可能性があります。

  • Pub/Sub ソース コネクタ: Managed Kafka サービス アカウントに、Pub/Sub サブスクリプションにアクセスする権限がない可能性があります。この問題を解決するには、マネージド Kafka サービス アカウントに次の両方の Identity and Access Management（IAM）ロールを付与します。

    • Pub/Sub サブスクライバー（roles/pubsub.subscriber）
    • Pub/Sub 閲覧者（roles/pubsub.viewer）

    詳細については、Pub/Sub サブスクリプションから読み取る権限を付与するをご覧ください。

  • Pub/Sub シンクコネクタ: Managed Kafka サービス アカウントに、Pub/Sub トピックにパブリッシュする権限がない可能性があります。この問題を解決するには、マネージド Kafka サービスに Pub/Sub パブリッシャー（roles/pubsub.publisher）IAM ロールを付与します。

    詳細については、Pub/Sub トピックに公開する権限を付与するをご覧ください。

サブスクリプションの確認でエラーが発生しました

Pub/Sub ソースコネクタが Pub/Sub サブスクリプションを見つけられない場合、コネクタは次のようなエラーで失敗します。

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

この問題を解決するには、コネクタの cps.subscription 構成で正しいサブスクリプションが指定されていることと、サブスクリプションがプロジェクトに存在することを確認します。

コネクタタスクでレコードの変換に失敗しました

コネクタのキー コンバータまたは値コンバータがレコードのデータ型と互換性がない場合、コネクタは次のようなエラーで失敗します。

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

この問題を解決するには、スキーマのデータ型をサポートするように、キー変換ツールまたは値変換ツールを正しいクラスに変更します。

たとえば、キー コンバータを ByteArrayConverter に設定すると、"Invalid schema type for ByteArrayConverter: STRING" エラーが発生することがあります。このエラーは、ByteArrayConverter が STRING 型をサポートしていないために発生します。代わりに、org.apache.kafka.connect.storage.StringConverter を使用してください。

次のステップ