Waiting for ack

未关闭
#359 3 条评论 0 个 reaction 已指派 0 人 在 GitHub 查看

还没有人认领这个 Issue。

评估

难度
4/5
预计耗时
3-5 天
新手友好度
25/100
Issue 类型
缺陷
描述清晰度
需要澄清
活跃度
停滞
技术栈
javascript, nodejs
领域
distributed-systems

调研方向

从示例中展示的 NodeJS 客户端 subscribe listener 和 acknowledgement 流程入手，检查 receiverQueueSize: 0 以及在 listener 外部执行的 acknowledgements 是如何处理的。复现只有一条消息在途的 subscription，并确定下一条消息是否会在 acknowledge(msg) 之前到达；当时序得到修正或受支持的行为得到文档说明时，即视为完成。

由索引模型根据 Issue 内容生成。

描述

I'm trying to consume 1 message at a time, and i'm acknowledging the message outside of the listener. But it's just grabbing the next message without waiting for the ack.

code sample:

let msg;
let msgConsumer;

const consumer = client.subscribe({
                    topic: `persistent://public/default/test1`,
                    subscription: `sub1`,
                    subscriptionType: 'Exclusive',
                    receiverQueueSize:0,
                    ackTimeoutMs:300000,
                    listener: (msg,msgConsumer) => {
                        console.log(msg.getData().toString());
                        msg = msg;
                        msgConsumer = msgConsumer;

                    }
                  });
                  
function someWhereElse(){

    msgConsumer.acknowledge(msg);


}

Is something like this possible?

主要语言
C++
星标
164
派生
99
平均合并
5 天 18 小时
30 天内合并 PR
2

贡献指南

这个仓库没有索引到贡献指南

从这里开始

  1. 先读完整个 Issue，再读项目的贡献指南。
  2. 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
  3. Fork 仓库，在一个分支上完成修改。
  4. 提交 Pull Request，并在描述里引用这个 Issue 编号。

apache/pulsar-client-node 的其他 Issue

查看 apache/pulsar-client-node 的全部 Issue

相似的 Issue

更多 C++ Issue

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。