modify to 1G

qmq-delay-server/src/main/java/qunar/tc/qmq/delay/MessageLogReplayer.java

@@ -30,16 +30,15 @@
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.atomic.LongAdder;
 import java.util.function.Function;
-
-import static qunar.tc.qmq.store.MessageLog.PER_SEGMENT_FILE_SIZE;
-
 /**
  * @author xufeng.deng [email protected]
  * @since 2018-07-19 17:43
  */
 public class MessageLogReplayer implements Switchable {
     private static final Logger LOGGER = LoggerFactory.getLogger(MessageLogReplayer.class);
+
     private static final RateLimiter LOG_LIMITER = RateLimiter.create((double) 1 / 6);
+
     private final DelayLogFacade facade;
     private final Thread dispatcherThread;
     private final LongAdder iterateFrom;

qmq-store/src/main/java/qunar/tc/qmq/store/MessageLog.java

@@ -33,7 +33,7 @@
 public class MessageLog implements AutoCloseable {
     private static final Logger LOG = LoggerFactory.getLogger(MessageLog.class);
 
-    public static final int PER_SEGMENT_FILE_SIZE = 100 * 1024 * 1024;
+    private static final int PER_SEGMENT_FILE_SIZE = 1024 * 1024 * 1024;
 
     //4 bytes magic code + 1 byte attribute + 8 bytes timestamp
     public static final int MIN_RECORD_BYTES = 13;