Clean the transport connection (#1161)

Signed-off-by: clyang82 <[email protected]>
Co-authored-by: clyang82 <[email protected]>

Author: openshift-cherrypick-robot

operator/pkg/controllers/hubofhubs/prune/prune_reconciler.go

@@ -61,7 +61,7 @@ func (r *PruneReconciler) Reconcile(ctx context.Context,
 				return true, err
 			}
 			if hasmanagedHub {
-				klog.Errorf("please detach all the managedhub clusters before uninstall globalhub")
+				klog.Errorf("You need to detach all the managed hub clusters before uninstalling")
 				return true, nil
 			}
 		}
@@ -83,6 +83,8 @@ func (r *PruneReconciler) Reconcile(ctx context.Context,
 		if err := r.MetricsResources(ctx); err != nil {
 			return true, err
 		}
+		// clean the kafka connection so that the manager can use the new one after reinstall
+		config.SetTransporterConn(nil)
 		return false, nil
 	}
 	// If webhook do not need to enable, should remove the related resources

operator/pkg/controllers/hubofhubs/transporter/protocol/strimzi_transporter.go

@@ -195,7 +195,7 @@ func (k *strimziTransporter) EnsureKafka() (bool, error) {
 	}
 
 	if !config.GetKafkaResourceReady() {
-		klog.Infof("Wait kafka crd ready")
+		klog.Infof("wait for the Kafka CRD to be ready")
 		return true, nil
 	}
 
@@ -599,7 +599,7 @@ func (k *strimziTransporter) kafkaClusterReady() (bool, error) {
 			return isReady, nil
 		}
 	}
-	klog.Infof("Wait kafka cluster ready")
+	klog.Infof("wait for the Kafka cluster to be ready")
 	return isReady, nil
 }