Memecahkan masalah konektor Pub/Sub

Bagian ini memberikan panduan pemecahan masalah untuk masalah umum yang terjadi saat menggunakan konektor sumber Pub/Sub atau konektor sink Pub/Sub.

Izin Pub/Sub tidak ada

Jika akun layanan Managed Kafka tidak memiliki izin untuk mengakses resource Pub/Sub, error berikut akan terjadi:

PERMISSION_DENIED: User not authorized to perform this action.

Error ini dapat terjadi karena beberapa alasan.

  • Konektor Sumber Pub/Sub: Akun layanan Managed Kafka mungkin tidak memiliki izin untuk mengakses langganan Pub/Sub. Untuk mengatasi masalah ini, berikan kedua peran Identity and Access Management (IAM) berikut kepada akun layanan Managed Kafka:

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

    Untuk mengetahui informasi selengkapnya, lihat Memberikan izin untuk membaca dari langganan Pub/Sub.

  • Konektor Pub/Sub Sink: Akun layanan Managed Kafka mungkin tidak memiliki izin untuk memublikasikan ke topik Pub/Sub. Untuk menyelesaikan masalah ini, berikan peran IAM Pub/Sub Publisher (roles/pubsub.publisher) kepada layanan Managed Kafka.

    Untuk mengetahui informasi selengkapnya, lihat Memberikan izin untuk memublikasikan ke topik Pub/Sub.

Terjadi error saat memverifikasi langganan

Jika konektor Sumber Pub/Sub tidak dapat menemukan langganan Pub/Sub, konektor akan gagal dengan error yang mirip dengan berikut ini:

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

Untuk mengatasi masalah ini, pastikan konfigurasi cps.subscription konektor menentukan langganan yang benar, dan langganan tersebut ada di project Anda.

Tugas konektor gagal mengonversi data

Jika pengonversi kunci atau pengonversi nilai konektor tidak kompatibel dengan jenis data rekaman, konektor akan gagal dengan error yang mirip dengan berikut:

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

Untuk mengatasi masalah ini, ubah pengonversi kunci atau pengonversi nilai ke class yang benar untuk mendukung jenis data skema.

Misalnya, jika Anda menetapkan konverter kunci ke ByteArrayConverter, Anda mungkin melihat error "Invalid schema type for ByteArrayConverter: STRING". Error ini terjadi karena ByteArrayConverter tidak mendukung jenis STRING. Sebagai gantinya, gunakan org.apache.kafka.connect.storage.StringConverter.

Langkah berikutnya