You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2025/04/17 20:00:48 UTC
(pulsar) 02/17: [fix][test] Update partitioned topic subscription assertions in IncrementPartitionsTest (#24056)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 39a1885f7f7ac02d1675b82c25ce418a2e3a38f9
Author: Shuta Kondo <ta...@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();
}