Skip to content

[feat] Add RandomReader to Pulsar client#25891

Open
dao-jun wants to merge 5 commits into
apache:masterfrom
dao-jun:feat/random_reader
Open

[feat] Add RandomReader to Pulsar client#25891
dao-jun wants to merge 5 commits into
apache:masterfrom
dao-jun:feat/random_reader

Conversation

@dao-jun
Copy link
Copy Markdown
Member

@dao-jun dao-jun commented May 29, 2026

Motivation

Add a new component RandomReader to Pulsar client.

The key method of RandomReader is

CompletableFuture<List<Message<T>>> read(MessageId startPosition, int numberOfBatches);

so it provides the ability to read messages from a specified location without create a ManagedCursor.

Modifications

  1. Proto changes for RandomReader
  2. Broker side support for RandomReader
  3. Add RandomReader public API to client

Verifying this change

  • Make sure that the change passes the CI checks.

(Please pick either of the following options)

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

(example:)

  • Added integration tests for end-to-end deployment with large payloads (10MB)
  • Extended integration test for recovery after broker failure

Does this pull request potentially affect one of the following parts:

If the box was checked, please highlight the changes

  • Dependencies (add or upgrade a dependency)
  • The public API
  • The schema
  • The default values of configurations
  • The threading model
  • The binary protocol
  • The REST endpoints
  • The admin CLI options
  • The metrics
  • Anything that affects deployment

@dao-jun dao-jun marked this pull request as draft May 29, 2026 20:33
@dao-jun dao-jun marked this pull request as ready for review May 29, 2026 20:34
@dao-jun
Copy link
Copy Markdown
Member Author

dao-jun commented May 29, 2026

The feat now is in progress, just create the PR to run ci checks

@dao-jun dao-jun force-pushed the feat/random_reader branch from fa4158a to da7e8d1 Compare June 2, 2026 10:08
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant