This is an automated email from the ASF dual-hosted git repository.

squah-confluent pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 1eec3d23fb9 MINOR: Fix non-idiomatic builder usage in 
TargetAssignmentBuilderTest (#22483)
1eec3d23fb9 is described below

commit 1eec3d23fb95ee3d413996e5129b024888328b5b
Author: Sean Quah <[email protected]>
AuthorDate: Thu Jun 25 13:14:49 2026 +0100

    MINOR: Fix non-idiomatic builder usage in TargetAssignmentBuilderTest 
(#22483)
    
    Reviewers: David Jacot <[email protected]>
---
 .../kafka/coordinator/group/streams/TargetAssignmentBuilderTest.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilderTest.java
 
b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilderTest.java
index dcce6b02461..9e59a60d088 100644
--- 
a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilderTest.java
+++ 
b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilderTest.java
@@ -839,6 +839,7 @@ public class TargetAssignmentBuilderTest {
             // Create and populate the assignment builder.
             org.apache.kafka.coordinator.group.streams.TargetAssignmentBuilder 
builder = new 
org.apache.kafka.coordinator.group.streams.TargetAssignmentBuilder(
                 groupId, groupEpoch, assignor, Map.of())
+                .withTime(new MockTime(0, assignmentTimestamp, 
assignmentTimestamp))
                 .withMembers(members)
                 .withTopology(topology)
                 .withStaticMembers(staticMembers)
@@ -855,9 +856,7 @@ public class TargetAssignmentBuilderTest {
             });
 
             // Execute the builder.
-            
org.apache.kafka.coordinator.group.streams.TargetAssignmentBuilder.TargetAssignmentResult
 result = builder
-                .withTime(new MockTime(0, assignmentTimestamp, 
assignmentTimestamp))
-                .build();
+            
org.apache.kafka.coordinator.group.streams.TargetAssignmentBuilder.TargetAssignmentResult
 result = builder.build();
 
             // Verify that the assignor was called once with the expected
             // assignment spec.

Reply via email to