(pulsar) 02/05: [fix][test] Update partitioned topic subscription assertions in IncrementPartitionsTest (#24056)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit d78bdcea4c6f22fe6ae6971e41b7956cbf7770af
Author: Shuta Kondo <takekon...@gmail.com>
AuthorDate: Wed Mar 12 11:01:49 2025 +0900

    [fix][test] Update partitioned topic subscription assertions in 
IncrementPartitionsTest (#24056)
    
    (cherry picked from commit 114aaf07f092933890d4b23514b7cde5016e24a9)
---
 .../org/apache/pulsar/broker/admin/IncrementPartitionsTest.java     | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/IncrementPartitionsTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/IncrementPartitionsTest.java
index 67997157b65..0032bb3f267 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/IncrementPartitionsTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/IncrementPartitionsTest.java
@@ -107,8 +107,10 @@ public class IncrementPartitionsTest extends 
MockedPulsarServiceBaseTest {
         admin.topics().updatePartitionedTopic(partitionedTopicName, 20);
         
assertEquals(admin.topics().getPartitionedTopicMetadata(partitionedTopicName).partitions,
 20);
 
-        assertEquals(admin.topics().getSubscriptions(
-                
TopicName.get(partitionedTopicName).getPartition(15).toString()), 
List.of("sub-1"));
+        for (TopicStats topic : 
admin.topics().getPartitionedStats(partitionedTopicName, true).getPartitions()
+                                .values()) {
+                assertEquals(topic.getSubscriptions().keySet(), 
List.of("sub-1"));
+        }
 
         consumer.close();
     }