Milvus mendukung empat MQ: rocksmq (berdasarkan RockDB), natsmq (embedded nats-server), Pulsar, dan Kafka.
Anda dapat mengubah mq Anda dengan mengatur bidang mq.type.
Jika Anda tidak mengatur bidang mq.type sebagai default, ada catatan tentang mengaktifkan prioritas jika kita mengkonfigurasi beberapa mq dalam berkas ini.
mode standalone (lokal): rocksmq (default) > natsmq > Pulsar > Kafka
mode cluster: Pulsar(default) > Kafka (rocksmq dan natsmq tidak didukung dalam mode cluster)
Deskripsi |
Nilai Default |
Nilai default: "default"
Nilai yang valid: [default, pulsar, kafka, rocksmq, natsmq] |
default |
Deskripsi |
Nilai Default |
Nilai default: "true" |
benar |
Deskripsi |
Nilai Default |
ambang batas jeda waktu detak untuk masuk ke mode pengejaran, dalam detik |
10 |
Deskripsi |
Nilai Default |
ukuran buffer mode pengejaran dalam byte |
8388608 |
Deskripsi |
Nilai Default |
waktu buffer mode pengejaran dalam detik |
60 |
Deskripsi |
Nilai Default |
Panjang buffer konsumen klien MQ |
16 |
Deskripsi |
Nilai Default |
waktu interval (dalam detik) bagi operator untuk memeriksa apakah akan menggabungkan |
1 |
Deskripsi |
Nilai Default |
pinjaman buffer saluran untuk target |
16 |
Deskripsi |
Nilai Default |
Nilai default: "3", batas waktu (dalam detik) yang digunakan target untuk mengirim msgPack |
3 |
Deskripsi |
Nilai Default |
Jumlah maksimum pengirim per saluran fisik, terutama untuk membatasi jumlah konsumen dan mencegah masalah kinerja (misalnya, selama pemulihan ketika sejumlah besar saluran ditonton). |
5 |
Deskripsi |
Nilai Default |
mendaftarkan waktu tidur coba ulang dalam detik |
3 |
Deskripsi |
Nilai Default |
mendaftarkan batas waktu coba ulang dalam detik |
60 |