View a markdown version of this page

Kegagalan - Amazon Managed Streaming untuk Apache Kafka

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Kegagalan

Anda dapat gagal kembali ke AWS Wilayah utama setelah acara layanan di Wilayah tersebut berakhir.

Identical topic name replication

  1. Buat Replikator MSK baru dengan cluster sekunder Anda sebagai sumber dan klaster utama sebagai target, posisi awal disetel ke replikasi nama topik yang paling awal dan identik (Simpan nama topik yang sama di konsol). Ini mulai menyalin semua data yang ditulis ke cluster sekunder setelah failover kembali ke Wilayah primer.

  2. Pantau MessageLag metrik pada replikator baru di Amazon CloudWatch hingga mencapai0, yang menunjukkan semua data telah direplikasi dari sekunder ke primer.

  3. Setelah semua data direplikasi, hentikan semua produsen yang terhubung ke cluster sekunder dan mulai produsen terhubung ke cluster primer.

  4. Tunggu MaxOffsetLag metrik untuk konsumen Anda terhubung ke cluster sekunder 0 untuk memastikan mereka telah memproses semua data. Lihat Pantau kelambatan konsumen.

  5. Setelah semua data diproses, hentikan konsumen di Wilayah sekunder dan mulai konsumen terhubung ke cluster utama untuk menyelesaikan failback.

  6. Hapus Replicator yang Anda buat pada langkah pertama yaitu mereplikasi data dari cluster sekunder Anda ke primer.

  7. Verifikasi bahwa data penyalinan Replicator yang ada dari klaster primer ke klaster sekunder memiliki status sebagai “RUNNING” dan ReplicatorThroughput metrik di Amazon CloudWatch lebih besar dari. 0

    Perhatikan bahwa saat Anda membuat Replicator baru dengan posisi awal sebagai Earliest for failback, Replicator mulai membaca semua data dalam topik cluster sekunder Anda. Bergantung pada pengaturan penyimpanan data Anda, topik Anda mungkin memiliki data yang berasal dari cluster sumber Anda. Sementara MSK Replicator secara otomatis memfilter pesan-pesan itu, Anda masih akan dikenakan biaya pemrosesan data dan transfer untuk semua data di cluster sekunder Anda. Anda dapat melacak total data yang diproses oleh replikator menggunakanReplicatorBytesInPerSec.

Prefixed topic name replication

Anda harus memulai langkah failback hanya setelah replikasi dari cluster di Region sekunder ke cluster di Wilayah primer telah menyusul dan metrik MessageLag di Amazon mendekati CloudWatch 0. Failback yang direncanakan seharusnya tidak mengakibatkan kehilangan data.

  1. Matikan semua produsen dan konsumen yang terhubung ke cluster MSK di Wilayah sekunder.

  2. Untuk topologi aktif-pasif, hapus Replicator yang mereplikasi data dari cluster di Region sekunder ke Region primer. Anda tidak perlu menghapus Replicator untuk topologi aktif-aktif.

  3. Mulai produsen yang terhubung ke cluster MSK di Wilayah utama.

  4. Jika aplikasi Anda tidak memerlukan pemesanan pesan, mulailah konsumen di AWS Wilayah utama yang membaca dari topik lokal dan yang direplikasi menggunakan operator wildcard. Jika aplikasi Anda memerlukan pemesanan pesan, mulailah konsumen hanya untuk topik yang direplikasi terlebih dahulu, tunggu jeda mencapai 0, lalu beralih ke topik lokal.

  5. Verifikasi bahwa Replicator yang ada dari cluster di Region primer ke cluster di Region sekunder dalam status RUNNING dan berfungsi seperti yang diharapkan menggunakan metrik ReplicatorThroughput dan latensi.