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

buger / goreplay

GoReplay is an open-source tool for capturing and replaying live HTTP traffic into a test environment in order to continuously test your system with real data. It can be used to increase confidence in code deployments, configuration changes and infrastructure changes.

https://goreplay.org

Other

18.42k stars 4 forks source link

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

Open g0ne150 opened 2 months ago

g0ne150 commented 2 months ago

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.

sonarcloud[bot] commented 2 months ago

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