Skip to content

Commit 4ff0ea7

Browse files
MINOR: Fix TargetAssignmentBuilderBenchmark (#22484)
Since KAFKA-20266, TargetAssignmentBuilder requires a Time instance to timestamp the assignment. Add one to TargetAssignmentBuilderBenchmark. Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
1 parent 9f19c79 commit 4ff0ea7

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/TargetAssignmentBuilderBenchmark.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
package org.apache.kafka.jmh.assignor;
1818

1919
import org.apache.kafka.common.Uuid;
20+
import org.apache.kafka.common.utils.Time;
2021
import org.apache.kafka.coordinator.common.runtime.CoordinatorMetadataImage;
2122
import org.apache.kafka.coordinator.group.api.assignor.GroupAssignment;
2223
import org.apache.kafka.coordinator.group.api.assignor.GroupSpec;
@@ -113,6 +114,7 @@ public void setup() {
113114
.build();
114115

115116
targetAssignmentBuilder = new TargetAssignmentBuilder.ConsumerTargetAssignmentBuilder(GROUP_ID, GROUP_EPOCH, partitionAssignor)
117+
.withTime(Time.SYSTEM)
116118
.withMembers(members)
117119
.withSubscriptionType(subscriptionType)
118120
.withTargetAssignment(existingTargetAssignment)

0 commit comments

Comments
 (0)