This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 13212012c9f70eaf701aa4c0e095c708996fdbdf Author: Baozi <[email protected]> AuthorDate: Wed Mar 16 19:00:01 2022 +0800 Flaky-test: SubscriptionSeekTest.testShouldCloseAllConsumersForMultipleConsumerDispatcherWhenSeek (#14674) (cherry picked from commit 157b808610ec6b4419da1caf6179aa26e90bfa3b) --- .../java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java index 8c5e969..76d8c0b 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java @@ -560,7 +560,7 @@ public class SubscriptionSeekTest extends BrokerTestBase { .subscriptionName("my-subscription") .subscribe(); - pulsarClient.newConsumer() + org.apache.pulsar.client.api.Consumer<byte[]> consumer2 = pulsarClient.newConsumer() .topic(topicName) .subscriptionType(SubscriptionType.Shared) .subscriptionName("my-subscription") @@ -579,12 +579,15 @@ public class SubscriptionSeekTest extends BrokerTestBase { consumer1.seek(MessageId.earliest); // Wait for consumer to reconnect Awaitility.await().until(consumer1::isConnected); + Awaitility.await().until(consumer2::isConnected); consumers = topicRef.getSubscriptions().get("my-subscription").getConsumers(); assertEquals(consumers.size(), 2); for (Consumer consumer : consumers) { assertFalse(connectedSinceSet.contains(consumer.getStats().getConnectedSince())); } + consumer1.close(); + consumer2.close(); } @Test
