lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(configuration): 补充新集群pulsar信息

Browse Source
This commit is contained in:
v-zhangjc9
2024-08-22 09:08:07 +08:00
parent 41555ef647
commit ec67fd30b6
1 changed files with 71 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/pulsar/PulsarInfo.java
View File

@@ -29,6 +29,38 @@ public class PulsarInfo {
"",
"132.122.113.167:18110"
),
new PulsarInfo(
"main-20240821",
Lists.immutable.of(
"132.121.204.145:16680",
"132.121.204.146:16680",
"132.121.204.147:16680",
"132.121.204.82:16680",
"132.121.204.83:16680",
"132.121.204.85:16680",
"132.121.204.91:16680",
"132.121.204.92:16680",
"132.121.204.99:16680"
),
"",
"132.121.204.145:18110"
),
new PulsarInfo(
"pg-20240821",
Lists.immutable.of(
"132.121.204.145:16690",
"132.121.204.146:16690",
"132.121.204.147:16690",
"132.121.204.82:16690",
"132.121.204.83:16690",
"132.121.204.85:16690",
"132.121.204.91:16690",
"132.121.204.92:16690",
"132.121.204.99:16690"
),
"",
"132.121.204.145:18120"
),
new PulsarInfo(
"acct",
Lists.immutable.of(
@@ -42,6 +74,19 @@ public class PulsarInfo {
"",
"132.122.115.158:18088"
),
new PulsarInfo(
"acct-20240821",
Lists.immutable.of(
"132.121.204.86:16650",
"132.121.204.94:16650",
"132.121.204.101:16650",
"132.121.204.84:16650",
"132.121.204.93:16650",
"132.121.204.100:16650"
),
"",
"132.121.204.86:18088"
),
new PulsarInfo(
"order",
Lists.immutable.of(
@@ -55,6 +100,19 @@ public class PulsarInfo {
"",
"132.122.115.158:18098"
),
new PulsarInfo(
"order-20240821",
Lists.immutable.of(
"132.121.223.21:16660",
"132.121.223.29:16660",
"132.121.223.30:16660",
"132.121.223.31:16660",
"132.121.223.1:16660",
"132.121.223.3:16660"
),
"",
"132.121.223.21:18098"
),
new PulsarInfo(
"cust",
Lists.immutable.of(
@@ -71,6 +129,19 @@ public class PulsarInfo {
),
"",
"132.122.113.167:18108"
),
new PulsarInfo(
"cust-20240821",
Lists.immutable.of(
"132.121.223.21:16670",
"132.121.223.29:16670",
"132.121.223.30:16670",
"132.121.223.31:16670",
"132.121.223.1:16670",
"132.121.223.3:16670"
),
"",
"132.121.223.21:18108"
)
);
public static final ImmutableMap<String, PulsarInfo> PULSAR_CLIENT_INFO_MAPPING = DEFAULT_INFOS