View a markdown version of this page

Gulung ke depan ke KCL 3.5.x setelah rollback dari KCL 3.5.x - Amazon Kinesis Data Streams

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

Gulung ke depan ke KCL 3.5.x setelah rollback dari KCL 3.5.x

Topik ini menjelaskan langkah-langkah untuk meneruskan konsumen Anda kembali ke KCL 3.5.x setelah rollback. Ketika Anda perlu meluncur ke depan, Anda harus melalui proses dua langkah:

  1. Jalankan Alat Migrasi KCL.

  2. Terapkan kode Tahap 2.

Langkah 1: Jalankan Alat Migrasi KCL

Jalankan Alat Migrasi KCL dengan perintah berikut untuk melanjutkan ke KCL 3.5.x:

python3 ./KclMigrationTool.py --region <region> --mode rollforward [--application_name <applicationName>] [--lease_table_name <leaseTableName>]

Parameter

  • --region: Ganti <region> dengan milik Anda Wilayah AWS.

  • --application_name: Parameter ini diperlukan jika Anda menggunakan nama default untuk tabel sewa Anda. Jika Anda telah menentukan nama khusus untuk tabel sewa, Anda dapat menghilangkan parameter ini. Ganti <applicationName> dengan nama aplikasi KCL Anda yang sebenarnya. Alat ini menggunakan nama ini untuk mendapatkan nama tabel default jika nama kustom tidak disediakan.

  • --lease_table_name (opsional): Parameter ini diperlukan ketika Anda telah menetapkan nama khusus untuk tabel sewa dalam konfigurasi KCL Anda. Jika Anda menggunakan nama tabel default, Anda dapat menghilangkan parameter ini. Ganti <leaseTableName> dengan nama tabel khusus yang Anda tentukan untuk tabel sewa Anda.

Setelah Anda menjalankan alat migrasi dalam mode roll-forward, KCL membuat resource DynamoDB berikut yang diperlukan untuk KCL 3.5.x:

  • Indeks Sekunder Global pada tabel sewa

catatan

KCL 3.5.x tidak membuat metrik pekerja terpisah atau tabel status koordinator selama migrasi. Semua metadata disimpan dalam tabel sewa.

Langkah 2: Terapkan kode dengan konfigurasi Tahap 2

Setelah menjalankan Alat Migrasi KCL untuk rollforward, terapkan kode Anda dengan konfigurasi KCL 3.5.x Phase 2 (CLIENT_VERSION_CONFIG_COMPATIBLE_WITH_2X) ke pekerja Anda. Ikuti Langkah 8: Selesaikan migrasi untuk menyelesaikan migrasi Anda.