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

Question

我在我的 node.js 服务器上使用kafka-node - 用于连接到 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);
});

编辑： 这是一个更大代码的 sn-p。 完整的流程是：

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);
});

我相信这会如你所愿。