Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Changing output kafka the same reqID message goes to the same partition. #1250

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Changing output kafka the same reqID message goes to the same partition. #1250

wants to merge 1 commit into from

Conversation

g0ne150
Copy link
Contributor

@g0ne150 g0ne150 commented Apr 22, 2024

The message with the same reqID should be in the same Kafka partition. Use the reqID as the message key, and the default value for Producer.Partitioner will be NewHashPartitioner, which selects the partition based on the hash value of the message key.

@dosubot dosubot bot added size:XS This PR changes 0-9 lines, ignoring generated files. enhancement New feature or feature request go Pull requests that update Go code labels Apr 22, 2024
@sonarcloud SonarCloud
Copy link

sonarcloud bot commented Apr 22, 2024

Quality Gate Passed Quality Gate passed

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
No data about Coverage
0.0% Duplication on New Code

See analysis details on SonarCloud

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
enhancement New feature or feature request go Pull requests that update Go code size:XS This PR changes 0-9 lines, ignoring generated files.
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
1 participant
@g0ne150