vamossagar12 edited a comment on pull request #10798: URL: https://github.com/apache/kafka/pull/10798#issuecomment-866823035
@guozhangwang / @cadonna I made some tweaks to the code and also started testing with 1M keys. Now I see differences in terms of throughput for both range and putAll queries around .3 ops/s and .15 ops/s respectively: Here is the compaision: ``` testPersistentRangeQueryPerformance original Benchmark Mode Cnt Score Error Units StreamsPersistentStoreBenchmark.testPersistentRangeQueryPerformance thrpt 15 1.131 ? 0.028 ops/s testPersistentPutAllPerformance original Benchmark Mode Cnt Score Error Units StreamsPersistentStoreBenchmark.testPersistentPutAllPerformance thrpt 15 0.919 ? 0.037 ops/s testPersistentRangeQueryPerformance bytebuffer StreamsPersistentStoreBenchmark.testPersistentRangeQueryPerformance thrpt 15 1.442 ? 0.038 ops/s Benchmark Mode Cnt Score Error Units StreamsPersistentStoreBenchmark.testPersistentPutAllPerformance thrpt 15 1.065 ? 0.041 ops/s ``` I needed to add ByteOrder after creating DirectByteBuffer object. And for putAll, i needed to flip before calling `put` to batch. Next step for me would be to create a kafka streams app and test throughput. I will post them here once i have those as well. -- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
