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

refactor(pulsar): 更新pulsar集群信息

Browse Source
This commit is contained in:
兰缘小妖
2023-12-07 09:26:48 +08:00
parent 9905c2c856
commit e7847528de
1 changed files with 27 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -68,6 +68,32 @@ public class PulsarInfo {
), ),
"132.122.113.169:58081", "132.122.113.169:58081",
"132.122.113.169:18108" "132.122.113.169:18108"
),
new PulsarInfo(
"acct-new",
ListUtil.of(
"132.122.115.158:16650",
"132.122.115.159:16650",
"132.122.115.160:16650",
"132.122.115.161:16650",
"132.122.115.167:16650",
"132.122.115.168:16650"
),
"",
"132.122.115.158:18088"
),
new PulsarInfo(
"order-new",
ListUtil.of(
"132.122.115.158:16660",
"132.122.115.159:16660",
"132.122.115.160:16660",
"132.122.115.161:16660",
"132.122.115.167:16660",
"132.122.115.168:16660"
),
"",
"132.122.115.158:18098"
) )
); );
public static final Map<String, PulsarInfo> PULSAR_CLIENT_INFO_MAPPING = DEFAULT_INFOS.stream() public static final Map<String, PulsarInfo> PULSAR_CLIENT_INFO_MAPPING = DEFAULT_INFOS.stream()
@@ -93,6 +119,7 @@ public class PulsarInfo {
private List<String> brokers; private List<String> brokers;
private String presto; private String presto;
private String admin; private String admin;
public PulsarInfo() { public PulsarInfo() {
} }