Fix errors

streamnative · Jan 29, 2024 · dc9cf43 · dc9cf43
1 parent 6dabcd9
commit dc9cf43
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/pulsar/resource_pulsar_namespace.go b/pulsar/resource_pulsar_namespace.go
@@ -791,16 +791,9 @@ func unmarshalTopicAutoCreation(v *schema.Set) (*utils.TopicAutoCreationConfig,
 		topicAutoCreation.Allow = data["enable"].(bool)
 		topicAutoCreation.Type = utils.TopicType(data["type"].(string))
 		if topicAutoCreation.Type == utils.Partitioned {
-			if data["partitions"] == nil {
-				return nil, fmt.Errorf("ERROR_PARSE_TOPIC_AUTO_CREATION: partitions is required for partitioned topic")
-			}
 			partitions := data["partitions"].(int)
 			topicAutoCreation.Partitions = &partitions
-		} else if topicAutoCreation.Type == utils.NonPartitioned {
-			if data["partitions"] != nil {
-				return nil, fmt.Errorf("ERROR_PARSE_TOPIC_AUTO_CREATION: partitions is not allowed for non-partitioned topic")
-			}
-		} else {
+		} else if topicAutoCreation.Type != utils.NonPartitioned {
 			return nil, fmt.Errorf("ERROR_PARSE_TOPIC_AUTO_CREATION: unknown topic type %s", topicAutoCreation.Type)
 		}
 	}