1 | 'use strict';
|
2 |
|
3 | exports.DEFAULT_TOPIC = 'TBW102';
|
4 | exports.DEFAULT_PRODUCER_GROUP = 'DEFAULT_PRODUCER';
|
5 | exports.DEFAULT_CONSUMER_GROUP = 'DEFAULT_CONSUMER';
|
6 | exports.CLIENT_INNER_PRODUCER_GROUP = 'CLIENT_INNER_PRODUCER';
|
7 |
|
8 | exports.DEFAULT_CHARSET = 'UTF-8';
|
9 | exports.MASTER_ID = 0;
|
10 |
|
11 | exports.RETRY_GROUP_TOPIC_PREFIX = '%RETRY%';
|
12 |
|
13 | exports.DLQ_GROUP_TOPIC_PREFIX = '%DLQ%';
|
14 |
|
15 |
|
16 |
|
17 |
|
18 |
|
19 |
|
20 | exports.getRetryTopic = consumerGroup => {
|
21 | return exports.RETRY_GROUP_TOPIC_PREFIX + consumerGroup;
|
22 | };
|
23 |
|
24 |
|
25 |
|
26 |
|
27 |
|
28 |
|
29 | exports.isRetryTopic = topic => {
|
30 | return topic && topic.startsWith(exports.RETRY_GROUP_TOPIC_PREFIX);
|
31 | };
|