diff --git a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/MessageIdCompareToTest.java b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/MessageIdCompareToTest.java index 850019d27ebf0..7e3dc7df3ef16 100644 --- a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/MessageIdCompareToTest.java +++ b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/MessageIdCompareToTest.java @@ -180,7 +180,7 @@ public void testBatchMessageIdImplCompareToTopicMessageId() { assertTrue(topicMessageId1.compareTo(messageIdImpl1) < 0, "Expected to be less than"); assertTrue(topicMessageId2.compareTo(messageIdImpl1) < 0, "Expected to be less than"); assertTrue(topicMessageId2.compareTo(messageIdImpl2) < 0, "Expected to be less than"); - assertTrue(topicMessageId2.compareTo(messageIdImpl2) < 0, "Expected to be less than"); + assertEquals(topicMessageId2.compareTo(messageIdImpl3), 0, "Expected to be equal"); } @SuppressWarnings("deprecation")