Pulsar 消耗重置与移动偏移量方法
发布时间
阅读量:
阅读量
Pulsar 消费重置涉及移动偏移量的操作,共有六种实现方式
- 在创建消费实例时,通过配置subscriptionInitialPosition参数进行设置。
- 利用consumer.seek(messageId)方法实现定位。
- 使用admin.topics().peekMessages(topicName,subsciptionName,numMessages)方法获取消息预览。
- 调用admin.topics().resetCursor(topicName,subsciptionName,messageTimestamp)方法重置游标位置。
- 运用admin.topics().skipMessages(String topic, String subName, long numMessages)方法跳过指定数量的消息。
- 执行admin.topics().skipAllMessages(String topic, String subName)方法跳过所有消息。
接下来将对上述各类方式的具体含义及实际测试情况进行说明。
1. 设置subscriptionInitialPosition
在构建consume时,可以设置`subscriptionInitialPosition(SubscriptionInitia
全部评论 (0)
还没有任何评论哟~
