Skip to content

Commit ec196f4

Browse files
authored
[fix][test] Fix flaky DisabledCreateTopicToRemoteClusterForReplicationTest (#24141)
1 parent f2618c1 commit ec196f4

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DisabledCreateTopicToRemoteClusterForReplicationTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ public void testCreatePartitionedTopicWithNsReplication() throws Exception {
108108
admin2.topics().createPartitionedTopic(tp, 1);
109109
Consumer<String> consumer2 = client2.newConsumer(Schema.STRING).topic(tp).isAckReceiptEnabled(true)
110110
.subscriptionName("s1").subscribe();
111-
assertEquals(consumer2.receive(10, TimeUnit.SECONDS).getValue(), msgValue);
111+
assertEquals(consumer2.receive(20, TimeUnit.SECONDS).getValue(), msgValue);
112112
consumer2.close();
113113

114114
// cleanup.

0 commit comments

Comments
 (0)