fix: BootstrapServerHost nil pointer (#269)

Co-authored-by: Enda Phelan <[email protected]>
redhat-developer · Jan 22, 2021 · e8eda42 · e8eda42
1 parent 8e59246
commit e8eda42
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/cluster/cluster.go b/pkg/cluster/cluster.go
@@ -106,6 +106,12 @@ func ConnectToCluster(connection pkgConnection.Connection,
 		return
 	}
 
+	if kafkaInstance.GetBootstrapServerHost() == "" {
+		// logger
+		fmt.Fprintf(os.Stderr, "Kafka instance is missing required BootstrapServerHost variable\n")
+		return
+	}
+
 	credentials := CreateCredentials(connection)
 	if credentials == nil {
 		return