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 5ddf347..fb6470a 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 @@ -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 PULSAR_CLIENT_INFO_MAPPING = DEFAULT_INFOS