We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7f6bc23 commit ff9f1b9Copy full SHA for ff9f1b9
1 file changed
pulsar-broker/src/test/java/org/apache/pulsar/client/api/PersistentTopicTerminateTest.java
@@ -64,8 +64,8 @@ public void testRecoverAfterTerminate() throws Exception {
64
assertEquals(msg2.getValue(), "2");
65
66
// Verify: the ledgers acked will be cleaned up.
67
- admin.topics().skipAllMessages(topicName, subscriptionName);
68
- Awaitility.await().untilAsserted(() -> {
+ consumer.acknowledgeCumulative(msg2);
+ Awaitility.await().atMost(30, TimeUnit.SECONDS).untilAsserted(() -> {
69
PersistentTopic persistentTopic =
70
(PersistentTopic) getTopic(topicName, false).join().get();
71
ManagedLedgerImpl ml = (ManagedLedgerImpl) persistentTopic.getManagedLedger();
0 commit comments