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

refactor(pulsar-query): 更新pulsar部署信息

Browse Source
This commit is contained in:
兰缘小妖
2024-01-12 10:28:27 +08:00
parent 5ac76062c4
commit c6e0a681bc
1 changed files with 35 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -16,61 +16,22 @@ public class PulsarInfo {
new PulsarInfo(
"main",
ListUtil.of(
"132.121.204.145:16680",
"132.121.204.147:16680",
"132.121.204.148:16680",
"132.121.204.82:16680",
"132.121.204.83:16680",
"132.121.204.85:16680",
"132.121.204.86:16680",
"132.121.204.94:16680",
"132.121.204.101:16680",
"132.121.223.3:16680"
"132.122.113.167:16680",
"132.122.113.168:16680",
"132.122.113.169:16680",
"132.122.113.170:16680",
"132.122.113.171:16680",
"132.122.113.172:16680",
"132.122.115.163:16680",
"132.122.115.164:16680",
"132.122.115.165:16680",
"132.122.115.166:16680"
),
"132.121.204.101:58081",
"132.121.204.101:18110"
"",
"132.122.113.167:18110"
),
new PulsarInfo(
"acct",
ListUtil.of(
"132.122.113.167:16650",
"132.122.113.168:16650",
"132.122.113.169:16650",
"132.122.113.170:16650",
"132.122.113.171:16650",
"132.122.113.172:16650"
),
"132.122.113.167:58081",
"132.122.113.167:18088"
),
new PulsarInfo(
"order",
ListUtil.of(
"132.122.113.171:16660",
"132.122.113.172:16660",
"132.122.113.173:16660",
"132.122.113.174:16660",
"132.122.113.175:16660",
"132.122.113.176:16660"
),
"132.122.113.171:58081",
"132.122.113.171:18098"
),
new PulsarInfo(
"cust",
ListUtil.of(
"132.122.113.169:16670",
"132.122.113.170:16670",
"132.122.113.173:16670",
"132.122.113.174:16670",
"132.122.113.175:16670",
"132.122.113.176:16670"
),
"132.122.113.169:58081",
"132.122.113.169:18108"
),
new PulsarInfo(
"acct-new",
ListUtil.of(
"132.122.115.158:16650",
"132.122.115.159:16650",
@@ -83,7 +44,7 @@ public class PulsarInfo {
"132.122.115.158:18088"
),
new PulsarInfo(
"order-new",
"order",
ListUtil.of(
"132.122.115.158:16660",
"132.122.115.159:16660",
@@ -94,6 +55,23 @@ public class PulsarInfo {
),
"",
"132.122.115.158:18098"
),
new PulsarInfo(
"cust",
ListUtil.of(
"132.122.113.167:16670",
"132.122.113.168:16670",
"132.122.113.169:16670",
"132.122.113.170:16670",
"132.122.113.171:16670",
"132.122.113.172:16670",
"132.122.115.163:16670",
"132.122.115.164:16670",
"132.122.115.165:16670",
"132.122.115.166:16670"
),
"",
"132.122.113.167:18108"
)
);
public static final Map<String, PulsarInfo> PULSAR_CLIENT_INFO_MAPPING = DEFAULT_INFOS.stream()
@@ -149,11 +127,11 @@ public class PulsarInfo {
@Override
public String toString() {
return "PulsarInfo{" +
"name='" + name + '\'' +
", brokers=" + brokers +
", presto='" + presto + '\'' +
", admin='" + admin + '\'' +
'}';
"name='" + name + '\'' +
", brokers=" + brokers +
", presto='" + presto + '\'' +
", admin='" + admin + '\'' +
'}';
}
private static final class Pair<L, R> {