-
Notifications
You must be signed in to change notification settings - Fork 3.7k
Description
Is your feature request related to a problem? Please describe.
Pulsar supports unload a non-partitioned-topic or a partition of a partitioned topic. If there has a partitioned topic with too many partitions, users need to get all partition and unload them one by one. We need to support unload all partition of a partitioned topic.
Describe the solution you'd like
Support unload all partition of a partitioned topic.
The implementation is similar to this:
pulsar/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
Line 890 in bdb1f4c
| PartitionedTopicMetadata partitionMetadata = getPartitionedTopicMetadata(topicName, authoritative, false); |
We need to get all partition of a partitioned topic if the topic is a partitioned topic and send
unload requests and waiting for them back.
Additional context
We need to add an integration test or unit test for verifying this change.
There has a similar unit test about REST API:
pulsar/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/PersistentTopicsTest.java
Line 136 in bdb1f4c
| public void testGetSubscriptions() { |