use wait for consumer/producer pods

Author: stevendongatmsft

.github/workflows/_test_workload.yml

@@ -41,8 +41,9 @@ jobs:
         run: | 
           az aks get-credentials --name $CLUSTER_NAME  --resource-group $RESOURCE_GROUP  --overwrite-existing
 
-          echo "Wait for 120 sec before checking expected Kafka message."
-          sleep 120
+          echo "Wait for pod readiness before checking expected Kafka message."
+          kubectl wait --for=condition=Ready=true -n kafka pod/kafka-golang-consumer --timeout=180s
+          kubectl wait --for=condition=Ready=true -n kafka pod/kafka-producer --timeout=180s
 
           max_retries=5
           retries=0