如何理解RocketMQ消费位置

这篇文章给大家介绍如何理解RocketMQ消费位置，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。RocketMQ创建消费者的时指定了Topic主题及Tag,我们发现新创建的消费者消费不了历史的数据，只能消费掉创建以后消费者发送的数据。这是什么原因，我们能把所有的消息都消费吗？，我们可以指定需要消费的消息的时间吗？答案是肯定的，下面我们具体分析一下。前提：我们讨论是集群模式下的，广播模式也是一样的，只是示例代码我们用集群模式来讨论。消息消费的位置目前提供了三种方式CONSUME_FROM_LAST_OFFSET（队列尾部消费）、CONSUME_FROM_FIRST_OFFSET（队列头部消费）、CONSUME_FROM_TIMESTAMP（指定消费时间点）。分析源码我们看到有6种方式，其他三种已经废弃掉了，不做讨论。我们从新创建一个消费组来消费某个主题下的消息时，历史消息没有被消费，当生产者重新发送消息时则会接收到最新的，我们分析下其在哪设置的。当创建消费者的时候内置了一些参数，从队列尾部消费。从队列尾部消费导致历史消息消费不了，会丢失一部分数据，如果仅仅是状态数据则可以这样设置，如果是业务数据导致数据丢失。对于设置这个参数仅对于消费组第一次创建时生效，后面再次设置不生效，因为该消费组在服务端已经记录了消费的进度，已有进度位置。查看消费进度文件的位置,我们根据上几节的内容查看TopicTest主题下的这个consumer_test_clustering消费组的消息消费的进度。查看Broker-a服务器节点上的信息。查看消费的消费进度先根据可视化界面查看查看服务器文件上的消费进度信息：/usr/local/rocketmq-all-4.2.0/store/config/consumerOffset.json编写Consumer设置了消费组：consumer.setConsumerGroup(“consumer_first_offset”);设置了消费位置：consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);查看其结果从头开始消费是指目前还储存在broker的上的消息全部消费一遍，因为RocketMQ会将消息持久化到磁盘文件中，时间长就会导致磁盘文件会很多，RocketMQ有一种机制，只是保留一段时间的消息，之前的消息会删除，可以指定时间点删除（无论消息是否被消费，到时间点文件都会被删除）消费者代码设置消费位置：consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_TIMESTAMP); 设置消费的时间点：consumer.setConsumeTimestam 香港云主机p(“20181222171201”);如果从消息进度服务OffsetStore读取到MessageQueue中的偏移量大于等于0，则使用读取到的偏移量，只有读取到的偏移量小于0时上述策略才会生效。关于如何理解RocketMQ消费位置就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。

相关推荐: git push本地项目如何推送到远程分支

本篇内容主要讲解“git push本地项目如何推送到远程分支”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“git push本地项目如何推送到远程分支”吧!初始化本地git仓库2.将本地文件索引添加至git库中3.4…