Consumer.acknowledge() not registered in client
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Idoneità per principianti
- 35/100
- Tipo di issue
- Bug
- Chiarezza
- Da chiarire
- Stato di attività
- Ferma
- Stack tecnologico
- javascript, node.js
- Ambito
- distributed-systems
Direzione di ricerca
Inizia riproducendo il ciclo while usando consumer.receive() e acknowledge() attorno alla chiamata di elaborazione di axios, confrontando l’acknowledgement prima e dopo la richiesta API. Verifica se receive() restituisce messaggi già acknowledged fino al suo timeout e usa pulsar-admin per confrontare lo stato della partizione del topic mentre il client è in esecuzione. Il lavoro è completato quando gli acknowledgement dopo l’elaborazione impediscono la consegna successiva di quei messaggi senza richiedere il riavvio del client.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
After receiving a message, our script makes an API call through axios to process the pulsar message. consumer.receive() and the processing logic runs in a while loop until receive() times out when the queue is empty.
It appears if we run acknowledge() prior to the API call, the client behaves correctly, that is messages are acked and receive does not receive any more messages once all messages are acked.
But running ack after the API call, the desired way to ack the message, it seems as receive() goes in a loop and keeps receiving messages already acked. However if we quit the script and re-run it, the queue is indeed empty and no messages are received, similarly peaking the messages through pulsar-admin for the given topic-partition while the script is running confirm messages are acked.
- Lingua principale
- C++
- Stelle
- 164
- Fork
- 99
- Merge medio
- 5g 18h
- PR unite (30g)
- 2
Preparare l'ambiente
- Nessun Dockerfile né file Docker Compose
- Ha un modello di pull request
- Nessuna guida per i contributori
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di apache/pulsar-client-node
-
Difficoltà 4/5 3-5 giorni Idoneità per principianti 35/100
apache/pulsar-client-node#477 ·
-
公司网络无法访问海外站点，如何解决？Aperta
Difficoltà 4/5 3-5 giorni Idoneità per principianti 35/100
apache/pulsar-client-node#455 · 3 commenti ·
-
Difficoltà 4/5 3-5 giorni Idoneità per principianti 35/100
apache/pulsar-client-node#432 · 2 reazioni ·
-
Difficoltà 3/5 1-2 giorni Idoneità per principianti 38/100
apache/pulsar-client-node#431 · 3 commenti ·
-
Difficoltà 3/5 1-2 giorni Idoneità per principianti 35/100
apache/pulsar-client-node#429 · 1 commento ·
Tutte le issue di apache/pulsar-client-node
Issue simili
-
HasBacktrace Priority-Critical
Difficoltà 2/5 1-3 ore Idoneità per principianti 78/100
azerothcore/azerothcore-wotlk#27921 ·
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 68/100
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 88/100
yhirose/cpp-peglib#344 ·
-
bug-unconfirmed
Difficoltà 2/5 1-3 ore Idoneità per principianti 76/100
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 70/100
shadps4-emu/shadps4-qtlauncher#453 ·
I maintainer di solito rispondono entro 2 giorni