Question

我正在不断阅读信息。如果没有任何信息可以读到,我想关闭我的客户和消费者。

下面的法典如果有读到的电文,但读到所封存的所有电文后,就会被罚款。 <代码>consumer.receive(>”方法阻止了整个方案。

我做了什么错误?

const RECEIVE_TIMEOUT = 100; // Adjust based on your needs

while (true) {
  const msg = await consumer.receive(RECEIVE_TIMEOUT);
  if (!msg) {
    // No message received within timeout, handle empty queue scenario
  } else {
    // Process the received message
    consumer.acknowledge(msg);
  }
}

Answer 1

I think the reader API is more suitable for this case. Here is the documentation https://pulsar.apache.org/docs/next/client-libraries-node-use/#create-a-reader

if (reader.hasNext()) {
    const msg = reader.readNext();
} else {
    reader.close();
    client.close();
}

友情链接