Skip to content

Comments

[java-client] Add support for key hash range reading.#5928

Merged
codelipenghui merged 3 commits intoapache:masterfrom
codelipenghui:key_range_reader
Jan 9, 2020
Merged

[java-client] Add support for key hash range reading.#5928
codelipenghui merged 3 commits intoapache:masterfrom
codelipenghui:key_range_reader

Conversation

@codelipenghui
Copy link
Contributor

@codelipenghui codelipenghui commented Dec 24, 2019

Master Issue: #4077

Motivation

Add support for sticky key hash range reader. Broker will only dispatch messages which hash of the message key contains by the specified key hash range.

Multiple key hash ranges can be specified on a reader by following example:

pulsarClient.newReader()
                    .topic(topic)
                    .startMessageId(MessageId.earliest)
                    .keyHashRange(Range.of(0, 10000), Range.of(20001, 30000))
                    .create();

Verifying this change

New unit tests was added for cover this change

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

If yes was chosen, please highlight the changes

  • Dependencies (does it add or upgrade a dependency): (no)
  • The public API: (yes )
  • The schema: (no)
  • The default values of configurations: (no)
  • The wire protocol: (no)
  • The rest endpoints: (no)
  • The admin cli options: (no)
  • Anything that affects deployment: (no)

Documentation

  • Does this pull request introduce a new feature? (yes)

@codelipenghui codelipenghui requested review from jiazhai, massakam, merlimat, rdhabalia and sijie and removed request for massakam, merlimat and rdhabalia December 24, 2019 08:46
@codelipenghui codelipenghui self-assigned this Dec 24, 2019
@codelipenghui codelipenghui mentioned this pull request Dec 24, 2019
Closed
12 tasks
@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 24, 2019

run java8 tests
run integration tests

@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 24, 2019

run cpp tests

@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 24, 2019

rerun java8 tests

1 similar comment
@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 24, 2019

rerun java8 tests

@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 24, 2019

run java8 tests
run integration tests

@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 24, 2019

run java8 tests

2 similar comments
@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 25, 2019

run java8 tests

@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 25, 2019

run java8 tests

@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 26, 2019

rerun java8 tests

2 similar comments
@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 26, 2019

rerun java8 tests

@codelipenghui
Copy link
Contributor Author

codelipenghui commented Dec 26, 2019

rerun java8 tests

@sijie sijie mentioned this pull request Dec 27, 2019
Closed
15 tasks
sijie
sijie approved these changes Jan 6, 2020
View reviewed changes
Copy link
Member

@sijie sijie left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM +1

@codelipenghui well done!

Can you rebase this pull request to master?

@sijie sijie added area/client java type/feature The PR added a new feature or issue requested a new feature labels Jan 6, 2020
@sijie sijie added this to the 2.6.0 milestone Jan 6, 2020
@codelipenghui
Copy link
Contributor Author

codelipenghui commented Jan 6, 2020

retest this please

1 similar comment
@codelipenghui
Copy link
Contributor Author

codelipenghui commented Jan 7, 2020

retest this please

@sijie
Copy link
Member

sijie commented Jan 8, 2020

run java8 tests
run integration tests

@codelipenghui
Copy link
Contributor Author

codelipenghui commented Jan 9, 2020

run integration tests

@codelipenghui codelipenghui merged commit 5fc4a90 into apache:master Jan 9, 2020
@sijie sijie mentioned this pull request Jan 14, 2020
Closed
@yjshen yjshen mentioned this pull request Feb 4, 2020
Closed
@sijie sijie mentioned this pull request May 20, 2020
Closed
huangdx0726 pushed a commit to huangdx0726/pulsar that referenced this pull request Aug 24, 2020
@codelipenghui @huangdx0726
[java-client] Add support for key hash range reading. (apache#5928)
a5a2716 
### Motivation

Add support for sticky key hash range reader. Broker will only dispatch messages which hash of the message key contains by  the specified key hash range. 

Multiple key hash ranges can be specified on a reader by following example:
```java
pulsarClient.newReader()
                    .topic(topic)
                    .startMessageId(MessageId.earliest)
                    .keyHashRange(Range.of(0, 10000), Range.of(20001, 30000))
                    .create();
```
@codelipenghui codelipenghui deleted the key_range_reader branch March 19, 2021 05:09
@codelipenghui codelipenghui added the doc-required Your PR changes impact docs and you will update later. label Mar 19, 2021
@amadav amadav mentioned this pull request Nov 14, 2022
Open
@Anonymitaet Anonymitaet added doc-complete Your PR changes impact docs and the related docs have been already added. and removed doc-required Your PR changes impact docs and you will update later. labels Feb 21, 2022
@Anonymitaet
Copy link
Member

Anonymitaet commented Feb 21, 2022

Doc is added
image

@sijie sijie mentioned this pull request May 27, 2022
Open
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@sijie sijie sijie approved these changes

@merlimat merlimat Awaiting requested review from merlimat

@jiazhai jiazhai Awaiting requested review from jiazhai

@rdhabalia rdhabalia Awaiting requested review from rdhabalia

@massakam massakam Awaiting requested review from massakam

Assignees

@codelipenghui codelipenghui

Labels

area/client doc-complete Your PR changes impact docs and the related docs have been already added. type/feature The PR added a new feature or issue requested a new feature

Projects

None yet

Milestone

2.6.0

Development

Successfully merging this pull request may close these issues.

3 participants

@codelipenghui @sijie @Anonymitaet