參數 version 4.6
1. consumerGroup 消費者分組
2. topic 主題
3. selectorType 消息選擇器類型
- 默認值 SelectorType.TAG 根據TAG選擇
僅支持表達式格式如:“tag1 || tag2 || tag3”,如果表達式為null或者“*”標識訂閱所有消息 - SelectorType.SQL92 根據SQL92表達式選擇
- 關鍵字:
AND, OR, NOT, BETWEEN, IN, TRUE, FALSE, IS, NULL - 數據類型:
Boolean, like: TRUE, FALSE
String, like: ‘abc’
Decimal, like: 123
Float number, like: 3.1415 - 語法:
AND, OR
>, >=, <, <=, =
BETWEEN A AND B, equals to >=A AND <=B
NOT BETWEEN A AND B, equals to >B OR <A
IN ('a', 'b'), equals to ='a' OR ='b', this operation only support String type.
IS NULL, IS NOT NULL, check parameter whether is null, or not.
=TRUE, =FALSE, check parameter whether is true, or false.
- 樣例:
(a > 10 AND a < 100) OR (b IS NOT NULL AND b=TRUE)
4. selectorExpression 選擇器表達式
默認值 ”*“
5. consumeMode 消費模式
- 默認值 ConsumeMode.CONCURRENTLY 並行處理
- ConsumeMode.ORDERLY 按順序處理
6. messageModel 消息模型
- 默認值 MessageModel.CLUSTERING 集群
- MessageModel.BROADCASTING 廣播
7. consumeThreadMax 最大線程數
默認值 64
8. consumeTimeout 超時時間
默認值 30000ms
9. accessKey
默認值 ${rocketmq.consumer.access-key:}
10. secretKey
默認值 ${rocketmq.consumer.secret-key:}
11. enableMsgTrace 啟用消息軌跡
默認值 true
12. customizedTraceTopic 自定義的消息軌跡主題
默認值 ${rocketmq.consumer.customized-trace-topic:}
沒有配置此配置項則使用默認的主題
13. nameServer 命名服務器地址
默認值 ${rocketmq.name-server:}
14. accessChannel
默認值 ${rocketmq.access-channel:}