apache / apache/pulsar-client-node
Waiting for ack
- Vorherrschende Sprache
- C++
- Sterne
- 164
- Forks
- 98
- PR-Merge-Kennzahlen
- Keine gemergten PRs in 30 T.
Beschreibung
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:
```js
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?
Beitragsleitfaden
Für dieses Repository ist kein Beitragsleitfaden indexiert
Rechercherichtung
Beginne beim subscribe-Listener und dem Bestätigungsablauf des NodeJS-Clients, wie sie im Beispiel gezeigt werden, und prüfe, wie receiverQueueSize: 0 und Bestätigungen, die außerhalb des Listeners vorgenommen werden, behandelt werden. Reproduziere das Abonnement mit genau einer Nachricht im Flug und stelle fest, ob die nächste Nachricht eintrifft, bevor acknowledge(msg) aufgerufen wird; erledigt ist die Aufgabe, wenn die Reihenfolge korrigiert oder das unterstützte Verhalten dokumentiert ist.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Bewertung
- Tech-Stack
- javascript, nodejs
- Bereich
- distributed-systems
- Issue-Typ
- Bug
- Schwierigkeit
- 4/5
- Geschätzter Aufwand
- 3-5 Tage
- Aktivitätsstatus
- Veraltet
- Klarheit
- Muss geklärt werden
- Anfängerfreundlichkeit
- 25/100