Skip to content

Commit 46e866a

Browse files
Update kafka-streams-partitioners/weighted-group-partitioner/src/test/java/org/hypertrace/core/kafkastreams/framework/partitioner/WeightedGroupPartitionerTest.java
Co-authored-by: Ravi Singal <[email protected]>
1 parent b38e64f commit 46e866a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka-streams-partitioners/weighted-group-partitioner/src/test/java/org/hypertrace/core/kafkastreams/framework/partitioner/WeightedGroupPartitionerTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -286,7 +286,7 @@ public void testWithNonMultipleRoundingWeightRatio() {
286286
.addGroups(newPartitionerGroup("group1", new String[] {"tenant-1"}, 37))
287287
.addGroups(
288288
newPartitionerGroup("group2", new String[] {"tenant-2", "tenant-3"}, 29))
289-
.addGroups(newPartitionerGroup("group1", new String[] {"tenant-4"}, 16))
289+
.addGroups(newPartitionerGroup("group3", new String[] {"tenant-4"}, 16))
290290
.setDefaultGroupWeight(20)
291291
.setName(profileName)
292292
.build());

0 commit comments

Comments
 (0)