feast-dev
diff --git a/‎core/src/main/java/feast/core/config/FeatureStreamConfig.java‎
Lines changed: 1 addition & 1 deletion b/‎core/src/main/java/feast/core/config/FeatureStreamConfig.java‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎storage/connectors/redis/src/main/java/feast/storage/connectors/redis/writer/RedisFeatureSink.java‎
Lines changed: 14 additions & 1 deletion b/‎storage/connectors/redis/src/main/java/feast/storage/connectors/redis/writer/RedisFeatureSink.java‎
Lines changed: 14 additions & 1 deletion
@@ -45,7 +45,7 @@ public class FeatureStreamConfig {
 
   String DEFAULT_KAFKA_REQUEST_TIMEOUT_MS_CONFIG = "15000";
   int DEFAULT_SPECS_TOPIC_PARTITIONING = 1;
-  short DEFAULT_SPECS_TOPIC_REPLICATION = 3;
+  short DEFAULT_SPECS_TOPIC_REPLICATION = 1;
 
   @Bean
   public KafkaAdmin admin(FeastProperties feastProperties) {
 
@@ -110,7 +110,20 @@ public PCollection<FeatureSetReference> prepareWrite(
           "At least one RedisConfig or RedisClusterConfig must be provided to Redis Sink");
     }
     specsView = featureSetSpecs.apply(ParDo.of(new ReferenceToString())).apply(View.asMultimap());
-    return featureSetSpecs.apply(Keys.create());
+    return featureSetSpecs
+        .apply(
+            "DummyDelay",
+            ParDo.of(
+                new DoFn<
+                    KV<FeatureSetReference, FeatureSetSpec>,
+                    KV<FeatureSetReference, FeatureSetSpec>>() {
+                  @ProcessElement
+                  public void process(ProcessContext c) throws InterruptedException {
+                    Thread.sleep(1000);
+                    c.output(c.element());
+                  }
+                }))
+        .apply(Keys.create());
   }
 
   @Override