UNPKG

1.06 kBJavaScriptView Raw
1'use strict';
2
3exports.DEFAULT_TOPIC = 'TBW102';
4exports.DEFAULT_PRODUCER_GROUP = 'DEFAULT_PRODUCER';
5exports.DEFAULT_CONSUMER_GROUP = 'DEFAULT_CONSUMER';
6exports.CLIENT_INNER_PRODUCER_GROUP = 'CLIENT_INNER_PRODUCER';
7
8exports.DEFAULT_CHARSET = 'UTF-8';
9exports.MASTER_ID = 0;
10// 为每个Consumer Group建立一个默认的Topic，前缀 + GroupName，用来保存处理失败需要重试的消息
11exports.RETRY_GROUP_TOPIC_PREFIX = '%RETRY%';
12// 为每个Consumer Group建立一个默认的Topic，前缀 + GroupName，用来保存重试多次都失败，接下来不再重试的消息
13exports.DLQ_GROUP_TOPIC_PREFIX = '%DLQ%';
14
15/**
16 * 获取 RETRY_TOPIC
17 * @param {string} consumerGroup consumerGroup
18 * @return {string} %RETRY%+consumerGroup
19 */
20exports.getRetryTopic = consumerGroup => {
21 return exports.RETRY_GROUP_TOPIC_PREFIX + consumerGroup;
22};
23
24/**
25 * 判断是否为 RETRY_TOPIC
26 * @param {String} topic topic
27 * @return {boolean} ret
28 */
29exports.isRetryTopic = topic => {
30 return topic && topic.startsWith(exports.RETRY_GROUP_TOPIC_PREFIX);
31};