CalvinConfluent opened a new pull request, #16075:
URL: https://github.com/apache/kafka/pull/16075
Skip using steam when expiring the producer ID. This can improve the
performance more than 30%
Before
```
Benchmark (numProducerIds) Mode Cnt
Score Error Units
ProducerStateManagerBench.testDeleteExpiringIds 10000 avgt 3
101.253 ± 28.031 us/op
ProducerStateManagerBench.testDeleteExpiringIds 100000 avgt 3
2297.219 ± 1690.486 us/op
ProducerStateManagerBench.testDeleteExpiringIds 1000000 avgt 3
30688.865 ± 16348.768 us/op
```
After
```
Benchmark (numProducerIds) Mode Cnt
Score Error Units
ProducerStateManagerBench.testDeleteExpiringIds 10000 avgt 3
61.181 ± 35.254 us/op
ProducerStateManagerBench.testDeleteExpiringIds 100000 avgt 3
1289.941 ± 121.026 us/op
ProducerStateManagerBench.testDeleteExpiringIds 1000000 avgt 3
21440.805 ± 5179.527 us/op
```
Also, made a change to the JMH testing which excludes the producer ID
populating from the testing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
