mq関連設定

Milvusはrocksmq(RockDBベース)、Pulsar、Kafka、Woodpeckerの4つのMQをサポートしています。

mq.typeフィールドを設定することでMQを変更することができます。

mq.typeフィールドをデフォルトに設定しない場合は、このファイルに複数のMQを設定する場合の優先順位の有効化に関する注意書きがあります。

  1. スタンドアロン(ローカル)モード: rocksmq(デフォルト) > Pulsar > Kafka

  2. クラスタモード: Pulsar(デフォルト) > Kafka (rocksmqはクラスタ・モードではサポートされていません)

  3. woodpeckerは、mq.typeをwoodpeckerに設定することで、スタンドアロン・モードとクラスタ・モードの両方で使用することができます。

mq.type

説明 デフォルト値
  • デフォルト値:"default"
  • 有効な値:[default、pulsar、kafka、rocksmq、woodpecker]。
  • デフォルト

    mq.enablePursuitMode

    説明 デフォルト値
    デフォルト値:"true"

    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