diff --git a/src/kafka-watcher/pkg/logwatcher/filewatcher.go b/src/kafka-watcher/pkg/logwatcher/filewatcher.go
index b5534f5a..b04df5bf 100644
--- a/src/kafka-watcher/pkg/logwatcher/filewatcher.go
+++ b/src/kafka-watcher/pkg/logwatcher/filewatcher.go
@@ -38,7 +38,7 @@ func (w *LogFileWatcher) RunForever(ctx context.Context) error {
 	go w.watchForever(ctx)
 
 	for {
-		time.Sleep(viper.GetDuration(config.KafkaCooldownIntervalKey))
+		time.Sleep(viper.GetDuration(config.KafkaReportIntervalKey))
 
 		if err := w.reportResults(ctx); err != nil {
 			logrus.WithError(err).Errorf("Failed reporting watcher results to mapper")
diff --git a/src/kafka-watcher/pkg/logwatcher/kubeneteslogwatcher.go b/src/kafka-watcher/pkg/logwatcher/kubeneteslogwatcher.go
index a6fded6c..c23d03f3 100644
--- a/src/kafka-watcher/pkg/logwatcher/kubeneteslogwatcher.go
+++ b/src/kafka-watcher/pkg/logwatcher/kubeneteslogwatcher.go
@@ -73,7 +73,7 @@ func (w *KubernetesLogWatcher) RunForever(ctx context.Context) error {
 	}
 
 	for {
-		time.Sleep(viper.GetDuration(config.KafkaCooldownIntervalKey))
+		time.Sleep(viper.GetDuration(config.KafkaReportIntervalKey))
 		if err := w.reportResults(ctx); err != nil {
 			logrus.WithError(err).Errorf("Failed reporting watcher results to mapper")
 		}