File tree Expand file tree Collapse file tree
store/src/main/java/org/apache/rocketmq/store Expand file tree Collapse file tree Original file line number Diff line number Diff line change 8282import org .apache .rocketmq .common .sysflag .MessageSysFlag ;
8383import org .apache .rocketmq .common .topic .TopicValidator ;
8484import org .apache .rocketmq .common .utils .CleanupPolicyUtils ;
85+ import org .apache .rocketmq .common .utils .NetworkUtil ;
8586import org .apache .rocketmq .common .utils .QueueTypeUtils ;
8687import org .apache .rocketmq .common .utils .ServiceProvider ;
8788import org .apache .rocketmq .common .utils .ThreadUtils ;
@@ -1197,8 +1198,7 @@ public long getEarliestMessageTime() {
11971198 minPhyOffset += DLedgerEntry .BODY_OFFSET ;
11981199 }
11991200 int size = MessageDecoder .MESSAGE_STORE_TIMESTAMP_POSITION + 8 ;
1200- InetAddressValidator validator = InetAddressValidator .getInstance ();
1201- if (validator .isValidInet6Address (this .brokerConfig .getBrokerIP1 ())) {
1201+ if (NetworkUtil .validCommonInet6Address (this .brokerConfig .getBrokerIP1 ())) {
12021202 size = MessageDecoder .MESSAGE_STORE_TIMESTAMP_POSITION + 20 ;
12031203 }
12041204 return this .getCommitLog ().pickupStoreTimestamp (minPhyOffset , size );
You can’t perform that action at this time.
0 commit comments