filter out empty kafka actions when expanding

spanio · Aug 29, 2023 · cb90ca2 · cb90ca2
1 parent bda97bc
commit cb90ca2
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/internal/service/iot/topic_rule.go b/internal/service/iot/topic_rule.go
@@ -1676,28 +1676,38 @@ func expandKafkaAction(tfList []interface{}) *iot.KafkaAction {
 	if len(tfList) == 0 || tfList[0] == nil {
 		return nil
 	}
+	empty := true
 
 	apiObject := &iot.KafkaAction{}
 	tfMap := tfList[0].(map[string]interface{})
 
 	if v, ok := tfMap["client_properties"].(map[string]interface{}); ok && len(v) > 0 {
 		apiObject.ClientProperties = flex.ExpandStringMap(v)
+		empty = false
 	}
 
 	if v, ok := tfMap["destination_arn"].(string); ok && v != "" {
 		apiObject.DestinationArn = aws.String(v)
+		empty = false
 	}
 
 	if v, ok := tfMap["key"].(string); ok && v != "" {
 		apiObject.Key = aws.String(v)
+		empty = false
 	}
 
 	if v, ok := tfMap["partition"].(string); ok && v != "" {
 		apiObject.Partition = aws.String(v)
+		empty = false
 	}
 
 	if v, ok := tfMap["topic"].(string); ok && v != "" {
 		apiObject.Topic = aws.String(v)
+		empty = false
+	}
+
+	if empty {
+		return nil
 	}
 
 	return apiObject