ApsaraMQ for RocketMQ：Parameter

Parameter

Deskripsi

NAMESRV_ADDR

TCP endpoint. Anda dapat memperoleh titik akhir di halaman Instance Details di Konsol ApsaraMQ for RocketMQ.

AccessKey

ID AccessKey yang digunakan untuk autentikasi. Untuk informasi tentang cara memperoleh ID AccessKey, lihat Buat pasangan AccessKey.

SecretKey

Rahasia AccessKey yang digunakan untuk autentikasi. Untuk informasi tentang cara memperoleh Rahasia AccessKey, lihat Buat pasangan AccessKey.

AccessChannel

Menentukan apakah akan menggunakan fitur jejak pesan di cloud. Jika Anda ingin menggunakan fitur jejak pesan di cloud, atur parameter ini ke CLOUD.

Parameter

Deskripsi

producerGroup

ID grup produser. Jika beberapa produser termasuk dalam aplikasi yang sama dan mengirimkan pesan yang sama, produser tersebut dianggap milik grup yang sama. Anda dapat memperoleh ID grup produser di konsol ApsaraMQ for RocketMQ. Untuk informasi lebih lanjut, lihat Istilah.

sendMsgTimeout

Periode timeout untuk mengirim pesan. Satuan: milidetik.

compressMsgBodyOverHowmuch

Menentukan ambang ukuran tubuh pesan untuk dikompres. Jika ukuran tubuh pesan melebihi ambang batas, pesan tersebut akan dikompres lalu didekompres saat diterima oleh konsumen. Nilai default: 4. Satuan: KB.

retryTimesWhenSendFailed

Jumlah maksimum percobaan ulang yang dapat dilakukan pada pesan jika pesan gagal dikirim. Parameter ini hanya berlaku untuk pesan yang dikirim dalam mode sinkron.

maxMessageSize

Ukuran pesan maksimum yang ditentukan oleh klien. Jika ukuran pesan melebihi nilai yang ditentukan oleh parameter ini, kesalahan akan dilaporkan. Broker juga memberlakukan batasan pada ukuran pesan. Parameter ini harus digunakan bersama dengan parameter yang sesuai di broker. Nilai default: 4. Satuan: MB.

Parameter

Deskripsi

consumerGroup

ID grup konsumen. Jika beberapa konsumen termasuk dalam aplikasi yang sama, berlangganan pesan yang sama, dan menggunakan logika konsumsi pesan yang sama, konsumen tersebut dianggap milik grup yang sama. Anda dapat memperoleh ID grup konsumen di konsol ApsaraMQ for RocketMQ. Untuk informasi lebih lanjut, lihat Istilah.

consumeFromWhere

Offset dari mana pesan dikonsumsi setelah grup konsumen dimulai. Secara default, pesan dikonsumsi dari offset terbaru.

consumeThreadMin

Jumlah minimum utas dalam kolam utas konsumen. Nilai default: 20.

consumeThreadMax

Jumlah maksimum utas dalam kolam utas konsumen. Nilai default: 20. Jumlah maksimum utas harus konsisten dengan jumlah minimum utas.

consumeConcurrentlyMaxSpan

Rentang offset maksimum yang diizinkan saat pesan dikonsumsi secara bersamaan dalam antrian. Nilai valid: 1 hingga 65535. Nilai default: 2000.

pullThresholdForQueue

Jumlah maksimum pesan yang dapat disimpan dalam cache di antrian lokal saat pesan ditarik. Nilai valid: 1 hingga 65535. Nilai default: 1000.

pullThresholdSizeForQueue

Ukuran total pesan yang dapat disimpan dalam cache di antrian lokal saat pesan ditarik. Nilai valid: 1 hingga 1024. Nilai default: 100. Satuan: MB.

maxReconsumeTimes

Jumlah maksimum percobaan ulang. Nilai default: 16.

suspendCurrentQueueTimeMillis

Interval waktu minimum antara dua percobaan ulang berturut-turut dari pesan terurut. Nilai valid: 10 hingga 30000. Nilai default: 1000. Satuan: milidetik.