apache / apache/pulsar-client-node

Waiting for ack

Aperta
#359 3 commenti 0 reazioni 0 assegnatari Vedi su GitHub
Lingua principale
C++
Stelle
164
Fork
98
Metriche di merge delle PR
Nessuna PR unita negli ultimi 30g

Descrizione

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?

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Direzione di ricerca

Inizia dal listener di subscribe e dal flusso di acknowledgement del client NodeJS mostrati nell'esempio, verificando come vengono gestiti receiverQueueSize: 0 e gli acknowledgement effettuati al di fuori del listener. Riproduci la sottoscrizione con un solo messaggio in volo e determina se il messaggio successivo arriva prima di acknowledge(msg); l'attività è completata quando la sequenza viene corretta oppure il comportamento supportato viene documentato.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Valutazione

Stack tecnologico
javascript, nodejs
Ambito
distributed-systems
Tipo di issue
Bug
Difficoltà
4/5
Tempo stimato
3-5 giorni
Stato di attività
Ferma
Chiarezza
Da chiarire
Idoneità per principianti
25/100

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.