(feat) make max.poll.records as required configs

Author: ylgrgyq

src/main/java/cn/leancloud/kafka/consumer/AutoCommitConsumerConfigs.java

@@ -4,7 +4,6 @@
 
 enum AutoCommitConsumerConfigs implements KafkaConfigsChecker {
     MAX_POLL_INTERVAL_MS("max.poll.interval.ms"),
-    MAX_POLL_RECORDS("max.poll.records"),
     AUTO_COMMIT_INTERVAL_MS("auto.commit.interval.ms");
 
     private String config;

src/main/java/cn/leancloud/kafka/consumer/AutoCommitPolicy.java

@@ -6,7 +6,7 @@
 import java.util.Collections;
 import java.util.Set;
 
-class AutoCommitPolicy<K, V> extends AbstractCommitPolicy<K, V> {
+final class AutoCommitPolicy<K, V> extends AbstractCommitPolicy<K, V> {
     AutoCommitPolicy(Consumer<K, V> consumer) {
         super(consumer);
     }

src/main/java/cn/leancloud/kafka/consumer/BasicConsumerConfigs.java

@@ -4,6 +4,7 @@
 
 enum BasicConsumerConfigs implements KafkaConfigsChecker {
     AUTO_OFFSET_RESET("auto.offset.reset"),
+    MAX_POLL_RECORDS("max.poll.records"),
     ENABLE_AUTO_COMMIT("enable.auto.commit", false);
 
     private String config;

src/main/java/cn/leancloud/kafka/consumer/CommitPolicy.java

@@ -5,7 +5,7 @@
 
 import java.util.Set;
 
-public interface CommitPolicy<K, V> {
+interface CommitPolicy<K, V> {
     void addPendingRecord(ConsumerRecord<K, V> record);
 
     void completeRecord(ConsumerRecord<K, V> record);

src/main/java/cn/leancloud/kafka/consumer/HandleMessageFailedException.java

@@ -1,6 +1,6 @@
 package cn.leancloud.kafka.consumer;
 
-public class HandleMessageFailedException extends RuntimeException {
+public final class HandleMessageFailedException extends RuntimeException {
     public HandleMessageFailedException() {
         super();
     }

src/main/java/cn/leancloud/kafka/consumer/SafetyNetMessageHandler.java

@@ -6,7 +6,7 @@
 
 import java.util.function.BiConsumer;
 
-public class SafetyNetMessageHandler<K, V> implements MessageHandler<K, V> {
+public final class SafetyNetMessageHandler<K, V> implements MessageHandler<K, V> {
     private static final Logger logger = LoggerFactory.getLogger(SafetyNetMessageHandler.class);
 
     private final MessageHandler<K, V> innerHandler;