ApsaraMQ for RocketMQ:Consumption Retry

Pemicu Retry

• Kegagalan konsumsi, termasuk mengembalikan status kegagalan atau melemparkan pengecualian tak terduga.

• Timeout pemrosesan pesan, termasuk timeout antrian pada PushConsumer.

Perilaku Upaya Ulang Utama

• Mesin keadaan retry: Mengontrol status pesan dan transisinya selama retry.

• Interval retry: Waktu antara kegagalan konsumsi (atau timeout) hingga pesan tersedia kembali untuk dikonsumsi ulang.

• Jumlah maksimum retry: Jumlah maksimum kali sebuah pesan dapat di-retry.

Perbedaan kebijakan retry pesan

Untuk kebijakan retry detail, lihat Kebijakan retry konsumsi PushConsumer dan Kebijakan retry konsumsi SimpleConsumer.

Mesin Keadaan Retry

Contoh: Pada diagram di atas, asumsikan pesan berada dalam status Ready selama 5 detik dan memerlukan 6 detik untuk diproses.

Setiap siklus retry mengikuti alur Ready → Inflight → WaitingRetry. Interval retry adalah waktu antara kegagalan (atau timeout) hingga pesan kembali menjadi Ready. Waktu aktual antara dua upaya konsumsi juga mencakup waktu pemrosesan dan durasi Ready. Contohnya:

• Pada detik ke-0, pesan memasuki status Ready.

• Karena kecepatan pemrosesan konsumen, konsumsi dimulai pada detik ke-5. Setelah 6 detik (pada detik ke-11), terjadi pengecualian dan klien mengembalikan kegagalan.

• Retry tidak dapat dimulai segera—harus menunggu interval retry.

• Pada detik ke-21, pesan kembali menjadi Ready.

• Klien mulai mengonsumsi ulang 5 detik kemudian.

Oleh karena itu, interval aktual antara dua upaya konsumsi adalah: waktu pemrosesan + interval retry + durasi Ready = 21 detik.

Interval Retry

• Pesan tidak terurut (pesan non-terurut): Interval retry menggunakan pendekatan waktu bertahap, sebagai berikut:

  Upaya Coba Lagi	Interval retry	Upaya Coba Lagi	Retry Interval
  1	10 detik	9	7 menit
  2	30 detik	10	8 menit
  3	1 menit	11	9 menit
  4	2 menit	12	10 menit
  5	3 menit	13	20 menit
  6	4 menit	14	30 menit
  7	5 menit	15	1 jam
  8	6 menit	16	2 jam

  Catatan

  Jika upaya retry melebihi 16, semua retry berikutnya menggunakan interval 2 jam.

• Pesan terurut: Gunakan interval retry tetap. Untuk nilai spesifiknya, lihat Batas parameter.

Jumlah Coba Ulang Maksimum

Untuk PushConsumer, jumlah maksimum retry dikontrol oleh metadata kelompok konsumen. Untuk mengubahnya, lihat Ubah jumlah maksimum retry.

Sebagai contoh, jika jumlah maksimum retry adalah 3, pesan dikirim hingga 4 kali: sekali awal dan tiga kali melalui retry.

Contoh Penggunaan

Untuk memicu retry di PushConsumer, cukup kembalikan kode status kegagalan konsumsi. Pengecualian tak terduga secara otomatis ditangkap oleh SDK.

SimpleConsumer simpleConsumer = null;
        // Contoh konsumsi: Gunakan PushConsumer untuk mengonsumsi pesan normal. Kembalikan error saat gagal untuk memicu retry.
        MessageListener messageListener = new MessageListener() {
            @Override
            public ConsumeResult consume(MessageView messageView) {
                System.out.println(messageView);
                // Kembalikan FAILURE untuk memicu retry otomatis hingga mencapai jumlah maksimum retry.
                return ConsumeResult.FAILURE;
            }
        };
            

Lihat Log Retry Konsumsi

Untuk pesan terurut, PushConsumer melakukan retry di sisi klien. Server tidak dapat mengakses log retry detail. Jika jejak pesan menunjukkan kegagalan pengiriman untuk pesan terurut, periksa log klien konsumen untuk informasi jumlah maksimum retry dan klien.

Untuk lokasi log klien, lihat Konfigurasi log.

Cari kata kunci berikut di log klien untuk menemukan detail kegagalan konsumsi dengan cepat:

Message listener raised an exception while consuming messages
Failed to consume fifo message finally, run out of attempt times

Mesin Keadaan Retry

Berbeda dengan PushConsumer, SimpleConsumer menggunakan interval retry yang dialokasikan sebelumnya. Saat mengambil pesan, konsumen mengatur parameter InvisibleDuration—waktu pemrosesan maksimum yang diizinkan. Saat terjadi kegagalan, interval retry berikutnya menggunakan kembali nilai ini tanpa konfigurasi tambahan.

Karena InvisibleDuration dialokasikan sebelumnya, nilainya mungkin sangat berbeda dari waktu pemrosesan aktual. Anda dapat mengubahnya melalui API.

Sebagai contoh, jika awalnya Anda mengatur waktu pemrosesan menjadi 20 ms tetapi pemrosesan aktual melebihi ini, perpanjang InvisibleDuration untuk menghindari retry prematur.

Seperti yang ditunjukkan di bawah, InvisibleDuration baru langsung berlaku—menyetel ulang timer invisibility sejak panggilan API dilakukan.

Interval Retry

Interval retry = InvisibleDuration − Waktu pemrosesan aktual

SimpleConsumer mengontrol interval retry melalui InvisibleDuration. Sebagai contoh, jika InvisibleDuration adalah 30 ms dan pemrosesan gagal setelah 10 ms, retry berikutnya terjadi setelah 20 ms. Jika pemrosesan tidak selesai dalam 30 ms dan tidak ada hasil yang dikembalikan, pesan timeout dan langsung di-retry (interval 0 ms).

Jumlah Upaya Ulang Maksimum

Untuk SimpleConsumer, jumlah maksimum retry dikontrol oleh metadata kelompok konsumen saat pembuatan. Untuk mengubahnya, lihat Ubah jumlah maksimum retry.

Sebagai contoh, jika jumlah maksimum retry adalah 3, pesan dikirim hingga 4 kali: sekali awal dan tiga kali melalui retry.

Contoh Penggunaan

Untuk memicu retry di SimpleConsumer, cukup tunggu.

 // Contoh konsumsi: Gunakan SimpleConsumer untuk mengonsumsi pesan normal. Untuk memicu retry, diam saja dan biarkan pesan timeout. Server akan secara otomatis melakukan retry.
        List<MessageView> messageViewList = null;
        try {
            messageViewList = simpleConsumer.receive(10, Duration.ofSeconds(30));
            messageViewList.forEach(messageView -> {
                System.out.println(messageView);
                // Saat gagal, abaikan pesan. Pesan akan kembali terlihat dan di-retry.
            });
        } catch (ClientException e) {
            // Jika pull gagal karena throttling atau masalah sistem lainnya, lakukan retry permintaan receive.
            e.printStackTrace();
        }

SDK gRPC

• Ubah melalui OpenAPI: Perbarui kelompok konsumen

• Ubah melalui Konsol:

  Untuk mengakses pengaturan:

  1. Pada halaman Instances, klik nama instans target.

  2. Di panel navigasi kiri, klik Groups. Pada halaman Groups, klik Create Group.

  Pada dialog Create Group, atur Group ID (1–60 karakter), Delivery Order (Concurrent Delivery atau Ordered Delivery), dan Description. Perluas Advanced Settings untuk mengonfigurasi kebijakan retry sebagai Exponential Backoff, atur Maximum Retry Count (default: 16), dan aktifkan/nonaktifkan Retain Dead-letter Messages (default: off; jika off, pesan yang melebihi jumlah retry akan dibuang).

SDK Remoting

• Ubah melalui parameter SDK Remoting: Atur properti maxReconsumeTimes pada konsumen.

Retry Secara Wajar—Hindari Menggunakan Retry untuk Rate Limiting

Seperti disebutkan dalam Skema Penggunaan, retry pesan cocok untuk kegagalan bisnis langka—bukan kegagalan sistemik atau berkelanjutan seperti rate limiting.

• Contoh salah:

  Jika laju konsumsi memicu throttling, kembalikan kegagalan dan tunggu retry.

• Contoh benar:

  Jika laju konsumsi memicu throttling, tunda pengambilan pesan dan konsumsi nanti.

Bagaimana Cara Mengatur Timeout Konsumsi Pesan?

consumer.setConsumeTimeout(15); // Satuan: menit. Rentang: 1–180 menit