diff --git a/internal/services/streamanalytics/stream_analytics_output_servicebus_topic_resource.go b/internal/services/streamanalytics/stream_analytics_output_servicebus_topic_resource.go
index 5d63b6ceb791..eaacd9fca158 100644
--- a/internal/services/streamanalytics/stream_analytics_output_servicebus_topic_resource.go
+++ b/internal/services/streamanalytics/stream_analytics_output_servicebus_topic_resource.go
@@ -146,11 +146,11 @@ func resourceStreamAnalyticsOutputServiceBusTopicCreateUpdate(d *pluginsdk.Resou
 
 	systemPropertyColumns := d.Get("system_property_columns").(map[string]interface{})
 	dataSourceProperties := &outputs.ServiceBusTopicOutputDataSourceProperties{
-		TopicName:              utils.String(d.Get("topic_name").(string)),
-		ServiceBusNamespace:    utils.String(d.Get("servicebus_namespace").(string)),
-		PropertyColumns:        utils.ExpandStringSlice(d.Get("property_columns").([]interface{})),
-		SystemPropertyColumns:  expandSystemPropertyColumns(systemPropertyColumns),
-		AuthenticationMode: utils.ToPtr(outputs.AuthenticationMode(d.Get("authentication_mode").(string))),
+		TopicName:             utils.String(d.Get("topic_name").(string)),
+		ServiceBusNamespace:   utils.String(d.Get("servicebus_namespace").(string)),
+		PropertyColumns:       utils.ExpandStringSlice(d.Get("property_columns").([]interface{})),
+		SystemPropertyColumns: expandSystemPropertyColumns(systemPropertyColumns),
+		AuthenticationMode:    utils.ToPtr(outputs.AuthenticationMode(d.Get("authentication_mode").(string))),
 	}
 
 	// Add shared access policy key/name only if required by authentication mode