From c6e0a681bcb5c324a6d10efd3edd3489fb38b6d5 Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Fri, 12 Jan 2024 10:28:27 +0800 Subject: [PATCH] =?UTF-8?q?refactor(pulsar-query):=20=E6=9B=B4=E6=96=B0pul?= =?UTF-8?q?sar=E9=83=A8=E7=BD=B2=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../entity/pulsar/PulsarInfo.java | 92 +++++++------------ 1 file changed, 35 insertions(+), 57 deletions(-) diff --git a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/pulsar/PulsarInfo.java b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/pulsar/PulsarInfo.java index 8223a9b..e1ab254 100644 --- a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/pulsar/PulsarInfo.java +++ b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/pulsar/PulsarInfo.java @@ -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 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 {