diff --git a/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/file/FileWatcher.java b/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/file/FileWatcher.java
index 9e3ee1d29a..d41fcc82a7 100644
--- a/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/file/FileWatcher.java
+++ b/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/file/FileWatcher.java
@@ -15,10 +15,8 @@
  */
 package dev.knative.eventing.kafka.broker.core.file;
 
-import static java.nio.file.StandardWatchEventKinds.ENTRY_CREATE;
-import static java.nio.file.StandardWatchEventKinds.ENTRY_DELETE;
-import static java.nio.file.StandardWatchEventKinds.ENTRY_MODIFY;
-import static java.nio.file.StandardWatchEventKinds.OVERFLOW;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.File;
 import java.io.IOException;
@@ -27,8 +25,8 @@
 import java.nio.file.WatchService;
 import java.util.Objects;
 import java.util.concurrent.CountDownLatch;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+
+import static java.nio.file.StandardWatchEventKinds.*;
 
 /**
  * This class is responsible for watching a given file and reports update or execute a trigger function.
@@ -128,6 +126,7 @@ public void run() {
             WatchKey key;
             try {
                 key = watcher.take();
+                Thread.sleep( 50 );
                 logger.debug("Contract updates");
             } catch (InterruptedException e) {
                 break; // Thread.interrupt was invoked
diff --git a/data-plane/core/src/test/java/dev/knative/eventing/kafka/broker/core/file/FileWatcherTest.java b/data-plane/core/src/test/java/dev/knative/eventing/kafka/broker/core/file/FileWatcherTest.java
index cc5d3cce7e..d0eab18711 100644
--- a/data-plane/core/src/test/java/dev/knative/eventing/kafka/broker/core/file/FileWatcherTest.java
+++ b/data-plane/core/src/test/java/dev/knative/eventing/kafka/broker/core/file/FileWatcherTest.java
@@ -43,6 +43,7 @@ public void tearDown() throws Exception {
     }
 
     @Test
+    @RepeatedTest(10)
     public void testFileModification() throws Exception {
         // Set up a counter to track how many times the trigger function is called
         AtomicInteger counter = new AtomicInteger(0);