带着这个问题继续往下看，代码太多就不贴上来了，总结下来就是在并发消费的情况下拉下来的消息超过一分钟没消费的话，就会将消息发送回broker端进行重试。本质上这两种方式都是客户端主动拉取消息，对于pop方式这是新版本中才有的模式，这种模式主要解决了以前一个消息队列被其某个consumer占用了导致消息堆积，现在pop模式会把消息分给其他消费者消费。在这个方法里面创建了一个PopCallback的类，

ElasticSearch创建文档、更新文档、搜索文档的流程介绍