fix

hstreamdb · Jan 4, 2024 · cba0f7f · cba0f7f
1 parent 9f09071
commit cba0f7f
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/hstream-kafka/HStream/Kafka/Server/Handler/Topic.hs b/hstream-kafka/HStream/Kafka/Server/Handler/Topic.hs
@@ -96,8 +96,10 @@ validateTopic [email protected]{..} = do
            else Left (K.INVALID_CONFIG, Just $ T.pack ("Null value not supported for topic configs: " <> show nullConfigs))
    validateNullConfig _ = Right topic
 
-   validateAssignments (K.unKaArray -> Just _) = Left (K.INVALID_REQUEST, unsuportedPartitionAssignments)
-   validateAssignments _                       = Right topic
+   validateAssignments (K.unKaArray -> Nothing) = Right topic
+   validateAssignments (K.unKaArray -> Just as)
+     | V.null as = Right topic
+   validateAssignments _ = Left (K.INVALID_REQUEST, unsuportedPartitionAssignments)
 
    validateReplica replica
      | replica < -1 || replica == 0 = Left (K.INVALID_REPLICATION_FACTOR, invalidReplicaMsg)