[feature request] Support Consumer.getLastMessageId
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 3/5
- Tempo stimato
- 1-2 giorni
- Idoneità per principianti
- 35/100
Direzione di ricerca
Inizia ispezionando la Consumer API nel repository pulsar-client-node e il supporto esistente di getLastMessageIdAsync nel client C++. Aggiungi quindi il metodo Consumer richiesto per il client Node e verifica che indichi se l'ultimo messaggio è stato letto, includendo la copertura per i consumer con un arretrato significativo.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
First off, thank you for all the development you do on Pulsar! 😄
Motivation
When combining data from two Consumers by event timestamps and the topics have significant backlog, it gets tricky to make sure that all relevant events have arrived. If we could check from the Consumer whether we have already read the latest message, that would simplify the code.
The C++ client already supports Consumer.getLastMessageIdAsync. (Though the Java client has deprecated the singular version of that method, supposedly due to the Consumers being able to subscribe to several topics concurrently. For us right now the singular version is enough.)
- Lingua principale
- C++
- Stelle
- 164
- Fork
- 99
- Merge medio
- 5g 18h
- PR unite (30g)
- 2
Guida per i contributori
Nessuna guida per i contributori indicizzata per questo repository
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
-
[CI] Nightly Clang build broken: structured binding captured in a lambda in FileDataSource.cpp Apertabug build
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 91/100
facebookincubator/velox#19194 ·
-
JIT-compiled number -> Decimal conversion silently overflows instead of raising DECIMAL_OVERFLOW Apertafuzz
Difficoltà 2/5 1-3 ore Idoneità per principianti 82/100
ClickHouse/ClickHouse#122114 ·
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 84/100
-
module/agent platform/macos type/bug/regression
Difficoltà 2/5 1-3 ore Idoneità per principianti 88/100
-
enhancement PyCDE
Difficoltà 2/5 1-3 ore Idoneità per principianti 78/100