root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix FetchSessionBenchmark (#11501) 

Reviewers: David Jacot <djacot@confluent.io>
This commit is contained in:
Justine Olshan 2021-11-16 01:39:35 -08:00 committed by GitHub
parent 627cad1f7b
commit 1c99c0ce15
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetchsession/FetchSessionBenchmark.java
View File

@ -99,7 +99,7 @@ public class FetchSessionBenchmark {
if (updatedPercentage != 0 && counter % (100 / updatedPercentage) == 0) {
// reorder in fetch session, and update log start offset
fetches.remove(topicPartition);
fetches.put(topicPartition, new FetchRequest.PartitionData(Uuid.ZERO_UUID, 50, 40, 200,
fetches.put(topicPartition, new FetchRequest.PartitionData(id, 50, 40, 200,
Optional.empty()));
}
counter++;
@ -115,7 +115,6 @@ public class FetchSessionBenchmark {
else
builder = handler.newBuilder();
// Should we keep lookup to mimic how adding really works?
for (Map.Entry<TopicPartition, FetchRequest.PartitionData> entry: fetches.entrySet()) {
TopicPartition topicPartition = entry.getKey();
builder.add(topicPartition, entry.getValue());