issue #36, searchByTime maxNums 改为配置.

src/main/java/com/xuxd/kafka/console/beans/QueryMessage.java

@@ -33,4 +33,6 @@ public class QueryMessage {
     private String headerKey;
 
     private String headerValue;
+
+    private int filterNumber;
 }

src/main/java/com/xuxd/kafka/console/beans/dto/QueryMessageDTO.java

@@ -37,6 +37,8 @@ public class QueryMessageDTO {
 
     private String headerValue;
 
+    private int filterNumber;
+
     public QueryMessage toQueryMessage() {
         QueryMessage queryMessage = new QueryMessage();
         queryMessage.setTopic(topic);
@@ -69,6 +71,7 @@ public class QueryMessageDTO {
         if (StringUtils.isNotBlank(headerValue)) {
             queryMessage.setHeaderValue(headerValue.trim());
         }
+        queryMessage.setFilterNumber(filterNumber);
 
         return queryMessage;
     }

src/main/java/com/xuxd/kafka/console/service/impl/MessageServiceImpl.java

@@ -70,7 +70,7 @@ public class MessageServiceImpl implements MessageService, ApplicationContextAwa
 
     @Override
     public ResponseData searchByTime(QueryMessage queryMessage) {
-        int maxNums = 5000;
+        int maxNums = queryMessage.getFilterNumber() <= 0 ? 5000 : queryMessage.getFilterNumber();
 
         Object searchContent = null;
         String headerKey = null;