diff --git a/cloud/data_source_pulsar_cluster.go b/cloud/data_source_pulsar_cluster.go index 1b900c3..8e142b7 100644 --- a/cloud/data_source_pulsar_cluster.go +++ b/cloud/data_source_pulsar_cluster.go @@ -334,12 +334,12 @@ func dataSourcePulsarClusterRead(ctx context.Context, d *schema.ResourceData, me return diag.FromErr(fmt.Errorf("ERROR_READ_PULSAR_CLUSTER_CONFIG: %w", err)) } } - if pulsarInstance.Spec.Type != cloudv1alpha1.PulsarInstanceTypeServerless { - brokerImage := strings.Split(pulsarCluster.Spec.Broker.Image, ":") - _ = d.Set("pulsar_version", brokerImage[1]) + if pulsarInstance.Spec.Type != cloudv1alpha1.PulsarInstanceTypeServerless && !pulsarCluster.IsUsingUrsaEngine() { bookkeeperImage := strings.Split(pulsarCluster.Spec.BookKeeper.Image, ":") _ = d.Set("bookkeeper_version", bookkeeperImage[1]) } + brokerImage := strings.Split(pulsarCluster.Spec.Broker.Image, ":") + _ = d.Set("pulsar_version", brokerImage[1]) _ = d.Set("type", pulsarInstance.Spec.Type) releaseChannel := pulsarCluster.Spec.ReleaseChannel if releaseChannel != "" {