apache / apache/pulsar-client-node

Waiting for ack

Ouverte
#359 3 commentaires 0 réactions 0 personnes assignées Voir sur GitHub
Langage dominant
C++
Étoiles
164
Forks
98
Métriques de merge des PR
Aucune PR mergée en 30 j

Description

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?

Guide de contribution

Aucun guide de contribution indexé pour ce dépôt

Piste de recherche

Commencez par le listener de subscription et le flux d’acknowledgement du client NodeJS présentés dans l’exemple, en vérifiant comment sont gérés receiverQueueSize: 0 et les acknowledgements effectués en dehors du listener. Reproduisez la subscription avec un seul message en vol et déterminez si le message suivant arrive avant acknowledge(msg) ; c’est terminé lorsque l’ordre est corrigé ou que le comportement pris en charge est documenté.

Rédigé par le modèle d'indexation à partir du texte de l'issue.

Évaluation

Stack technique
javascript, nodejs
Domaine
distributed-systems
Type d'issue
Bug
Difficulté
4/5
Temps estimé
3-5 jours
Activité
À l'abandon
Clarté
À clarifier
Accessibilité débutants
25/100

Recevez les nouvelles issues par e-mail

Un résumé court des issues GitHub adaptées aux débutants.