fix

dajac · Jun 30, 2023 · a3d7e76 · a3d7e76
1 parent 40fcd86
commit a3d7e76
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...rdinator/src/test/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroupTest.java b/...rdinator/src/test/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroupTest.java
@@ -564,9 +564,9 @@ public void testMetadataRefreshDeadline() {
         assertTrue(group.hasMetadataExpired(time.milliseconds()));
 
         // Set the refresh time deadline with a higher group epoch.
-        group.setMetadataRefreshDeadline(time.milliseconds() + 1000, group.groupEpoch() + 1);
+        group.setMetadataRefreshDeadline(time.milliseconds(), group.groupEpoch() + 1);
         assertTrue(group.hasMetadataExpired(time.milliseconds()));
-        assertEquals(time.milliseconds() + 1000, group.metadataRefreshDeadline().deadlineMs);
+        assertEquals(time.milliseconds(), group.metadataRefreshDeadline().deadlineMs);
         assertEquals(group.groupEpoch() + 1, group.metadataRefreshDeadline().epoch);
 
         // Set the refresh deadline.