Applying same fix as PR apache#6846

kafkaesque-io · Apr 29, 2020 · 570634a · 570634a
1 parent 09f32d1
commit 570634a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -1859,6 +1859,7 @@ public CompletableFuture<PartitionedTopicMetadata> fetchPartitionedTopicMetadata
                                 // If topic is already exist, creating partitioned topic is not allowed.
                                 if (metadata.partitions == 0
                                         && !topicExists
+                                        && !topicName.isPartitioned()
                                         && pulsar.getConfiguration().isAllowAutoTopicCreation()
                                         && pulsar.getConfiguration().isDefaultTopicTypePartitioned()) {
                                     return pulsar.getBrokerService().createDefaultPartitionedTopicAsync(topicName);