dynamically get the ingestion consumer group expected member count

Issue: ZENKO-4286
scality · Jan 28, 2025 · c47e76d · c47e76d
1 parent df09662
commit c47e76d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.github/scripts/end2end/configure-e2e.sh b/.github/scripts/end2end/configure-e2e.sh
@@ -111,4 +111,5 @@ kubectl wait --for condition=DeploymentFailure=false --timeout 25m -n ${NAMESPAC
 kubectl wait --for condition=DeploymentInProgress=false --timeout 25m -n ${NAMESPACE} zenko/${ZENKO_NAME}
 
 # wait for ingestion processor to start consuming from Kafka
-wait_for_consumer_group $NAMESPACE $UUID.backbeat-ingestion-group 1 300
+ingestion_processor_replicas=$(kubectl -n $NAMESPACE get deploy/end2end-backbeat-ingestion-processor -o jsonpath='{.spec.replicas}')
+wait_for_consumer_group $NAMESPACE $UUID.backbeat-ingestion-group $ingestion_processor_replicas 300