fix test case error

Author: Technoboy-

pulsar-broker/src/test/java/org/apache/pulsar/client/api/TopicReaderTest.java

@@ -940,7 +940,7 @@ public void testMessageAvailableAfterRestart() throws Exception {
 
         try (Reader<byte[]> reader = pulsarClient.newReader().topic(topic)
             .startMessageId(MessageId.earliest).create()) {
-            assertFalse(reader.hasMessageAvailable());
+            assertTrue(reader.hasMessageAvailable());
         }
 
         try (Producer<byte[]> producer = pulsarClient.newProducer().topic(topic).create()) {

pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MultiTopicsReaderTest.java

@@ -101,7 +101,7 @@ public void testReadMessageWithoutBatchingWithMessageInclusive() throws Exceptio
             Assert.assertTrue(keys.remove(reader.readNext(1, TimeUnit.SECONDS).getKey()));
             count++;
         }
-        Assert.assertEquals(count, topicNum);
+        Assert.assertEquals(count, 1);
         Assert.assertFalse(reader.hasMessageAvailable());
     }
 

pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java

@@ -186,7 +186,7 @@ public void testBinaryProtoToGetTopicsOfNamespacePersistent() throws Exception {
 
         assertEquals(topics.size(), 6);
         assertEquals(consumers.size(), 6);
-        assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitionedTopics().size(), 3);
+        assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitionedTopics().size(), 2);
 
         topics.forEach(topic -> log.debug("topic: {}", topic));
         consumers.forEach(c -> log.debug("consumer: {}", c.getTopic()));
@@ -289,7 +289,7 @@ public void testBinaryProtoToGetTopicsOfNamespaceNonPersistent() throws Exceptio
 
         assertEquals(topics.size(), 1);
         assertEquals(consumers.size(), 1);
-        assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitionedTopics().size(), 1);
+        assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitionedTopics().size(), 0);
 
         topics.forEach(topic -> log.debug("topic: {}", topic));
         consumers.forEach(c -> log.debug("consumer: {}", c.getTopic()));
@@ -649,7 +649,7 @@ public void testAutoSubscribePatternConsumer() throws Exception {
         Thread.sleep(100);
         assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitions().size(), 10);
         assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getConsumers().size(), 10);
-        assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitionedTopics().size(), 4);
+        assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitionedTopics().size(), 3);
 
         // 8. produce data to topic3 and topic4, verify should receive all the message
         for (int i = 0; i < totalMessages / 2; i++) {