This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit b8e074f33826b532c28ea9bfb9d68ddfe16a5a74 Author: Tboy <techno...@apache.org> AuthorDate: Mon Jun 28 23:12:06 2021 +0800 Fix Flaky-test: [TopicFromMessageTest].[testMultiTopicConsumerBatchShortName] (#11124) (#11125) Fixes #11124 . (cherry picked from commit e647bd08fd775e513c356976bef1d82c0ac38907) --- .../java/org/apache/pulsar/client/impl/TopicFromMessageTest.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicFromMessageTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicFromMessageTest.java index 5ad4b51..6863235 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicFromMessageTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicFromMessageTest.java @@ -107,8 +107,12 @@ public class TopicFromMessageTest extends ProducerConsumerBase { producer1.send("foobar".getBytes()); producer2.send("foobar".getBytes()); - Assert.assertEquals(consumer.receive().getTopicName(), "persistent://public/default/topic1"); - Assert.assertEquals(consumer.receive().getTopicName(), "persistent://public/default/topic2"); + // We can't ensure the received order of the message. + String topicNameX = consumer.receive().getTopicName(); + String topicNameY = consumer.receive().getTopicName(); + Object[] actualTopicNames = new Object[]{topicNameX, topicNameY}; + Object[] expectedTopicNames = new Object[]{"persistent://public/default/topic1", "persistent://public/default/topic2"}; + Assert.assertEqualsNoOrder(actualTopicNames, expectedTopicNames); } }