Advertisement

Pulsar 消耗重置与移动偏移量方法

阅读量:

Pulsar 消费重置涉及移动偏移量的操作,共有六种实现方式

  1. 在创建消费实例时,通过配置subscriptionInitialPosition参数进行设置。
  2. 利用consumer.seek(messageId)方法实现定位。
  3. 使用admin.topics().peekMessages(topicName,subsciptionName,numMessages)方法获取消息预览。
  4. 调用admin.topics().resetCursor(topicName,subsciptionName,messageTimestamp)方法重置游标位置。
  5. 运用admin.topics().skipMessages(String topic, String subName, long numMessages)方法跳过指定数量的消息。
  6. 执行admin.topics().skipAllMessages(String topic, String subName)方法跳过所有消息。

接下来将对上述各类方式的具体含义及实际测试情况进行说明。

1. 设置subscriptionInitialPosition

在构建consume时,可以设置`subscriptionInitialPosition(SubscriptionInitia

全部评论 (0)

还没有任何评论哟~