Bagian ini memberikan panduan pemecahan masalah untuk masalah umum yang terjadi saat menggunakan konektor Sink Cloud Storage.
Deserialisasi salah dikonfigurasi
Jika konverter konektor tidak cocok dengan data di Kafka, konektor akan gagal dengan pesan error yang serupa dengan berikut ini:
org.apache.kafka.connect.errors.DataException: Converting byte[] to Kafka
Connect data failed due to serialization error:
Untuk mengatasi masalah ini, pastikan pengonversi kunci dan nilai untuk konektor cocok dengan data yang dibaca konektor dari Kafka.
Misalnya, jika Anda menetapkan jenis output format ke csv dan pengonversi nilai
ke JsonConverter, Anda mungkin melihat error berikut:
org.apache.kafka.connect.errors.DataException: Converting byte[] to Kafka
Connect data failed due to serialization error:
at org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:333)
at org.apache.kafka.connect.storage.Converter.toConnectData(Converter.java:91)
Error ini terjadi karena output CSV memerlukan ByteArrayConverter untuk konverter nilai, bukan JsonConverter. Untuk mengetahui informasi selengkapnya, lihat
Cara kerja konektor Sink Cloud Storage.
Stack trace dalam log dapat membantu menemukan akar masalah. Misalnya, entri log berikut menunjukkan masalah saat mengonversi karakter UTF-32:
Caused by: org.apache.kafka.common.errors.SerializationException:
java.io.CharConversionException: Invalid UTF-32 character 0x31d086a
(above 0x0010ffff) at char #1, byte #7
Izin bucket Cloud Storage tidak ada
Jika akun layanan Managed Kafka tidak memiliki izin untuk menulis ke bucket Cloud Storage, konektor akan gagal dengan pesan error yang mirip dengan berikut ini:
org.apache.kafka.connect.errors.ConnectException:
com.google.cloud.storage.StorageException: 403 Forbidden
Untuk mengatasi masalah ini, berikan peran Storage Object Creator
(roles/storage.objectCreator) ke akun layanan Managed Kafka. Untuk mengetahui informasi selengkapnya, lihat Memberikan izin untuk menulis ke bucket Cloud Storage.