Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
dynamically get the ingestion consumer group expected member count
Browse files Browse the repository at this point in the history
Issue: ZENKO-4286
Kerkesni committed Jan 28, 2025
1 parent 9389c08 commit e4c754b
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion .github/scripts/end2end/configure-e2e.sh
Original file line number Diff line number Diff line change
@@ -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/artesca-data-backbeat-ingestion-processor -o jsonpath='{.spec.replicas}')
wait_for_consumer_group $NAMESPACE $UUID.backbeat-ingestion-group $ingestion_processor_replicas 300

0 comments on commit e4c754b

Please sign in to comment.