kafka消费端消费一批消息时有时候开头几条消息没有被消费到是什么问题？

消费端在消费消息时，有时一批消息开头几条消息消费端感觉像没有拉取到，猜测会不会是上一次拉去消息的时候把后面几个偏移量消费了？但是这不应该把。不知道具体是什么问题，该如何找问题呢？我是用的同步+异步的方式提交的偏移量。新建了一个servlet项目启动时初始化servlet的init方法来启动的线程。servlet的destroy调用时也就是项目关闭时去结束while循环，然后调用consumer.commitSync();同步提交的方法。

代码如下

 public Consumer(String servers, String topicName, boolean flag) {
    Properties props = new Properties();
    props.put("bootstrap.servers", servers);
    props.put("group.id", GROUPID);
    props.put("enable.auto.commit", "false");
    props.put("auto.commit.interval.ms", "1000");
    props.put("session.timeout.ms", "30000");
    props.put("auto.offset.reset", "earliest");
    props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, "1");//获取记录数
    props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, "300000");//处理消息最大间隔时间
    props.put("key.deserializer", StringDeserializer.class.getName());
    props.put("value.deserializer", StringDeserializer.class.getName());
    this.consumer = new KafkaConsumer<String, String>(props);
    this.topic = topicName;
    this.flag=flag;
    this.consumer.subscribe(Arrays.asList(topic));
}

@Override
public void run() {
    logger.info("---------kafka消费端开始消费---------");
    Gson gson = new Gson();
    try {
        while(flag){
            msgList = consumer.poll(1000);
            if(null!=msgList&&msgList.count()>0){
                for (ConsumerRecord<String, String> record : msgList) {
                    String reqJson = record.value();
                    ProposalSaveFor3105RequestDto baseRequestDto = null;
                    try {
                        baseRequestDto = gson.fromJson(reqJson,ProposalSaveFor3105RequestDto.class);
                        String proposalNo = baseRequestDto.getPolicyDataDto().getInsuredItemProcutDtoList().get(0).getInsuredDto().getProposalNo();
                        logger.info("kafka拉取了单号："+proposalNo);
                    }catch (Exception e){
                        e.printStackTrace();
                        logger.error("kafka消费端异常---转换报文报错---报文内容："+reqJson+"，异常信息：",e);
                    }
                    if(baseRequestDto!=null){
                        try {
                            KafkaProposalSaveFor3105ServiceImpl service = new KafkaProposalSaveFor3105ServiceImpl();
                            service.saveProposal(baseRequestDto);
                        }catch (Exception e){
                            e.printStackTrace();
                            logger.error("kafka消费端业务逻辑执行异常---异常信息：",e);
                        }
                    }
                }
                consumer.commitAsync();
            }
        }
    } catch (Exception e) {
        logger.error("kafka消费端消费信息时异常---异常信息：",e);
        e.printStackTrace();
    } finally {
        try {
            consumer.commitSync();
        }catch (Exception e1){
            e1.printStackTrace();
        }finally {
            consumer.close();
        }
    }
}

程序没有报错。
偶尔会出现这样的问题，不知道是不是我消费端写的哪里有什么问题。求大神分析分析，谢谢。