Reapply "[test] Update epoch rewind test to allow EOP replay policy"

This reverts commit 7acb8c8.

Author: pthirun

clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java

@@ -87,8 +87,15 @@ public void testUserProvidedEpochRewind() {
     }
   }
 
+  /**
+   * With epoch passthrough (rewindEpochTimeInSecondsOverride), the absolute epoch timestamp flows
+   * directly through the pipeline, so the SOP/EOP replay policy no longer matters. EOP stores
+   * should be allowed to use epoch-based rewind without throwing. Previously this test asserted
+   * that EOP + epoch override would throw — that restriction has been removed.
+   * See design: DESIGN_rewind_epoch_passthrough.md, Section 3.4.5.
+   */
   @Test
-  public void testUserProvidedEpochRewindWithInvalidRemotePolicy() {
+  public void testUserProvidedEpochRewindWithEOPPolicy() {
     final int singleColoCurrentVersion = 1;
     ControllerClient controllerClient = mock(ControllerClient.class);
     Map<String, Integer> coloToVersionMap = Collections.emptyMap();
@@ -105,7 +112,8 @@ public void testUserProvidedEpochRewindWithInvalidRemotePolicy() {
       venicePushJob.setControllerClient(controllerClient);
       venicePushJob.initKIFRepushDetails();
       venicePushJob.setControllerClient(controllerClient);
-      Assert.assertThrows(venicePushJob::validateRemoteHybridSettings);
+      // Should NOT throw — epoch rewind works with any replay policy (SOP or EOP)
+      venicePushJob.validateRemoteHybridSettings();
     }
   }