MQ 관련 구성

밀버스는 락스엠큐(RockDB 기반), 펄서, 카프카, 우드페커의 네 가지 MQ를 지원합니다.

mq.type 필드를 설정하여 mq를 변경할 수 있습니다.

mq.type 필드를 기본값으로 설정하지 않으면 이 파일에 여러 개의 mq를 구성하는 경우 우선순위를 활성화하는 것에 대한 참고 사항이 있습니다.

  1. 독립형(로컬) 모드: rocksmq(기본값) > Pulsar > Kafka

  2. 클러스터 모드: Pulsar(기본값) > Kafka(클러스터 모드에서 rocksmq는 지원되지 않음)

  3. 독립형과 클러스터 모드에서 모두 사용하려면 mq.type을 woodpecker로 설정하면 됩니다.

mq.type

설명 기본값
  • 기본값입니다: "default"
  • 유효한 값: [default, pulsar, kafka, rocksmq, 딱따구리]
  • default

    mq.enablePursuitMode

    설명 기본값
    기본값입니다: "true" 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