apache / apache/pulsar-client-node

[feature request] Support Consumer.getLastMessageId

Open
#349 0 comments 1 reaction 0 assignees View on GitHub
Dominant language
C++
Stars
164
Forks
98
PR merge metrics
No merged PRs in 30d

Description

First off, thank you for all the development you do on Pulsar! :smile:

### 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.)

Contributor guide

No contributing guide indexed for this repository

Research direction

Start by inspecting the Consumer API in the pulsar-client-node repository and the existing C++ client's getLastMessageIdAsync support. Add the requested Consumer method for the Node client, then verify that it reports whether the latest message has been read, including coverage for consumers with significant backlog.

Written by the indexing model from the issue text.

Assessment

Tech stack
cpp, node.js
Domain
api
Issue type
Feature
Difficulty
3/5
Estimated time
1-2 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.