javascript - kafka-node - 将参数传递给异步函数consumer.on()；

Question

我正在使用kafka-node对于我的 node.js 服务器 - 用于连接到 kafka 主题。在他们的API中有一个回调函数:

consumer.on('message', function (message) {
     console.log(message);
});

用于在消息到达时使用它们。

我想知道是否以及如何向此回调函数添加参数，因为我不是在消息到达时调用它的人。

更具体地说，我想发送预期的 ID 并将其与消费的消息 ID 进行比较:

consumer.on('message', function (message, id) {
    if (id == message.id) 
        console.log(message);
});

编辑:这是较大代码的片段。完整流程为:

1. 用户向 Node.js 服务器发出 http 请求。
2. GET HTTP 请求在 Node.js 服务器中触发。
3. kafka 生产者向外部系统发送一些消息(具有唯一 ID)并等待响应。
4. 收到对 kafka 消费者的响应。将收到的消息 id 与预期 id 进行比较 - 如果相等 - 将消息作为 http 响应返回。

考虑可以并行接收多个http get 请求。

Answer 1

您无法向回调添加参数。但我相信您可以实现您想要做的事情，而无需这样做 - 只需引用闭包范围内的变量即可。

例如，如果您有:

var id = 1001;

consumer.on('message', function(message) {
  if (id == message.id) console.log(message);
});

我相信这会达到你想要的效果。