Set replicas as 1

Signed-off-by: chandankumar4 <[email protected]>
numaproj · Dec 13, 2023 · e6e29d0 · e6e29d0
1 parent 7047914
commit e6e29d0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/test/idle-source-e2e/idle_source_test.go b/test/idle-source-e2e/idle_source_test.go
@@ -90,7 +90,7 @@ func (is *IdleSourceSuite) TestIdleKeyedReducePipelineWithKafkaSource() {
 	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Minute)
 	defer cancel()
 
-	topic := CreateKafkaTopic("2", "2")
+	topic := CreateKafkaTopic("2", "1")
 	fileData, err := os.ReadFile("testdata/kafka-pipeline.yaml")
 	is.NoError(err)
 	updatedFileData := strings.ReplaceAll(string(fileData), "my-topic", topic)