We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 47f3223 commit 114aaf0Copy full SHA for 114aaf0
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/IncrementPartitionsTest.java
@@ -107,8 +107,10 @@ public void testIncrementPartitionsOfTopic() throws Exception {
107
admin.topics().updatePartitionedTopic(partitionedTopicName, 20);
108
assertEquals(admin.topics().getPartitionedTopicMetadata(partitionedTopicName).partitions, 20);
109
110
- assertEquals(admin.topics().getSubscriptions(
111
- TopicName.get(partitionedTopicName).getPartition(15).toString()), List.of("sub-1"));
+ for (TopicStats topic : admin.topics().getPartitionedStats(partitionedTopicName, true).getPartitions()
+ .values()) {
112
+ assertEquals(topic.getSubscriptions().keySet(), List.of("sub-1"));
113
+ }
114
115
consumer.close();
116
}
0 commit comments