队列配置

本节主要介绍pan的队列配置，主要是消息队列例如kafka、rabbitmq、rocketmq、nsq的相关配置。

  1. [KafkaProxy]
  2. enable=true
  3. KafkaWaitAll=true
  4. KafkaCompression=true
  5. KafkaPartitioner=round  //可选round、random、hash
  6. KafkaProducerTimeout=10 //单位s
  7. brokers=localhost:9092
  8. sasl=false
  9. user=
  10. password=
  11. valid=
  12. failMode=retry/save/discard(无限次重试、保存到redis、丢弃)
  14. [RabbitmqProxy]
  15. enable=false
  16. url=amqp://guest:guest@localhost:5672/
  17. valid=test:test log:test
  18. failMode=retry/save/discard(无限次重试、保存到redis、丢弃)
  20. [RocketmqProxy]
  21. enable=false
  22. producerGroup=test
  23. nameServer=127.0.0.1:9876
  24. producerRetry=2
  25. valid=TopicTest
  26. failMode=retry/save/discard(无限次重试、保存到redis、丢弃)
  28. [NSQProxy]
  29. enable=false
  30. nsqdAddr=127.0.0.1:4150
  31. valid=test
  32. failMode=retry/save/discard(无限次重试、保存到redis、丢弃)
  34. [DelayMQProxy]
  35. enable=false
  36. key=delay_queue //延时队列key名称
  37. limit=1000 //zrange命令一次取数据最大限制，建议设置为1000
  • kafka队列配置主要包括broker地址，kafka压缩方式，是否启用kafka等
  • rabbitmq配置主要包括是否启用rabbitmq、rabbitmq地址
  • rocketmq配置主要包括是否启用rocketmq、nameserver地址等
  • nsq配置主要包括是否启用nsq、nsqd地址
  • delaymq配置主要包括是否开始延时功能配置