@Test
   public void testMaxMessageSizeWithChunking() throws Exception {
       this.conf.setMaxMessageSize(10);

       @Cleanup
       Producer<byte[]> producer = pulsarClient.newProducer()
               .topic(persistenceTopic)
               .enableChunking(true)
               .enableBatching(false)
               .create();

       PersistentTopic topic = (PersistentTopic) pulsar.getBrokerService().getTopic(persistenceTopic,false).join().get();

       byte[] data = new byte[100];
       producer.send(data);

       // success with maxMessageSize is 10
       admin.topicPolicies().setMaxMessageSize(persistenceTopic, 10);
       Awaitility.await().untilAsserted(() -> {
           Assert.assertEquals((int) topic.getHierarchyTopicPolicies().getTopicMaxMessageSize().get(), 10);
       });
       producer.send(data);

       // failed with maxMessageSize is 9
       admin.topicPolicies().setMaxMessageSize(persistenceTopic, 9);
       Awaitility.await().untilAsserted(() -> {
           Assert.assertEquals((int) topic.getHierarchyTopicPolicies().getTopicMaxMessageSize().get(), 9);
       });
       producer.send(data);
   }