triton-doc

triton develop document

Project maintained by tal-tech Hosted on GitHub Pages — Theme by mattgraham

队列配置

本节主要介绍triton的队列配置，主要包含四种消息队列，分别是kafka、rabbitmq、rocketmq、nsq，配置文件格式为json

{
  "enabled": {
    "kafka": true,
    "rabbitmq": false,
    "rocketmq": false,
    "nsq": false
  },
  "kafka": [
    {
      "consumerGroup": "test0",
      "consumerCount": 1,
      "host": [
        "127.0.0.1:9092"
      ],
      "sasl": {
        "enabled": false,
        "user": "",
        "password": ""
      },
      "topic": "test",
      "failTopic": "xes_exercise_fail",
      "tplMode": 1,
      "batchSize": 5,
      "batchTimeout": 10000,
      "tplName": ""
    }
  ],
  "nsq": [
    {
      "consumerCount": 2,
      "nsqLookup": [
        "127.0.0.1:4161"
      ],
      "topic": "test",
      "channel": "nsq",
      "tplMode": 0
    }
  ],
  "rocketmq": [
    {
      "consumerGroup": "test0",
      "consumerMode": 0,
      "nameServer": [
        "127.0.0.1:9876"
      ],
      "topic": "TopicTest",
      "tags": "stu_test_0",
      "offset": 0,
      "retry": 2,
      "consumerCount": 1,
      "tplMode": 1
    }
  ],
  "rabbitmq": [
    {
      "url": "amqp://guest:guest@localhost:5672/",
      "consumerQueue": "test",
      "failExchange": "failExchange",
      "failCount": 3,
      "isReject": true,
      "prefetchCount": 10,
      "consumerCount": 2,
      "tplMode": 1
    }
  ]
}