التكوينات المتعلقة بـ mq

يدعم Milvus أربعة من MQ: rocksmq (استنادًا إلى RockDB) وPulsar وKafka وWoodpecker.

يمكنك تغيير mq الخاص بك عن طريق تعيين حقل mq.type.

إذا لم تقم بتعيين حقل mq.type كإعداد افتراضي، فهناك ملاحظة حول تمكين الأولوية إذا قمنا بتكوين عدة mq في هذا الملف.

1. الوضع المستقل (المحلي): وضع مستقل (محلي): rocksmq (افتراضي) > بولسار > كافكا

2. الوضع العنقودي: بولسار(افتراضي) > كافكا (روكسمك غير مدعوم في وضع التجميع)

3. يمكن استخدام نقار الخشب في كل من الوضع المستقل ووضع المجموعة عن طريق تعيين mq.type إلى نقار الخشب.

mq.type

الوصف	القيمة الافتراضية
القيمة الافتراضية: "افتراضي" قيم صالحة: [افتراضي، بولسار، كافكا، روكسمك، نقار الخشب]	افتراضي

mq.enablePursuitMode

الوصف	القيمة الافتراضية
القيمة الافتراضية: "صحيح"	صواب

mq.pursuitLag

الوصف	القيمة الافتراضية
حد التأخر الزمني للدخول في وضع المطاردة، بالثواني	10

mq.pursuitBufferSize

الوصف	القيمة الافتراضية
حجم المخزن المؤقت لوضع المطاردة بالبايت	8388608

mq.pursuitBufferTime

الوصف	القيمة الافتراضية
وقت المخزن المؤقت لوضع المطاردة بالثواني	60

mq.mqBufSize

الوصف	القيمة الافتراضية
طول المخزن المؤقت لمستهلك عميل MQ	16

mq.dispatcher.mergeCheckInterval

الوصف	القيمة الافتراضية
الوقت الفاصل الزمني (بالثواني) للمرسل للتحقق من الدمج من عدمه	1

mq.dispatcher.targetBufSize

الوصف	القيمة الافتراضية
طول المخزن المؤقت للقناة من أجل الترجيع	16

mq.dispatcher.maxTolerantLag

الوصف	القيمة الافتراضية
القيمة الافتراضية "3"، المهلة (بالثواني) التي يرسلها الهدف msgPack	3

mq.dispatcher.maxDispatcherNumPerPchannel

الوصف	القيمة الافتراضية
الحد الأقصى لعدد المرسلات لكل قناة فعلية، وذلك في المقام الأول للحد من عدد المستهلكين ومنع حدوث مشاكل في الأداء (على سبيل المثال، أثناء الاسترداد عند مشاهدة عدد كبير من القنوات).	5

mq.dispatcher.retrySleep

الوصف	القيمة الافتراضية
وقت سكون إعادة محاولة التسجيل بالثواني	3

mq.dispatcher.retryTimeout

الوصف	القيمة الافتراضية
مهلة إعادة محاولة التسجيل بالثواني	60