rocketmq 如何使用C++的接口去获取topic下的某个queue的最大偏移量,设置消费者组的

rocketmq 如何使用C++的接口去获取topic下的某个queue的最大偏移量,设置消费者组的偏移量

展开
收起
游客nhc6zbz4vthk6 2022-02-22 16:16:02 2383 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • private RemotingCommand getMaxOffset(ChannelHandlerContext ctx,
            RemotingCommand request) throws RemotingCommandException {
            final RemotingCommand response = RemotingCommand.createResponseCommand(GetMaxOffsetResponseHeader.class);
            final GetMaxOffsetResponseHeader responseHeader = (GetMaxOffsetResponseHeader) response.readCustomHeader();
            final GetMaxOffsetRequestHeader requestHeader =
                (GetMaxOffsetRequestHeader) request.decodeCommandCustomHeader(GetMaxOffsetRequestHeader.class);
    
    //        根据topic和queueId获取最大的offset
            long offset = this.brokerController.getMessageStore().getMaxOffsetInQueue(requestHeader.getTopic(), requestHeader.getQueueId());
    
            responseHeader.setOffset(offset);
    
            response.setCode(ResponseCode.SUCCESS);
            response.setRemark(null);
            return response;
        }
    
    
    2022-05-20 08:10:33 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

还有其他疑问?
咨询AI助理