Skip to content
This repository was archived by the owner on Apr 1, 2024. It is now read-only.

ISSUE-13360: [Bug] Produce chunk messages failed when topic level maxMessageSize is set. #3442

Closed
sijie opened this issue Dec 16, 2021 · 1 comment

Comments

@sijie
Copy link
Member

sijie commented Dec 16, 2021

Original Issue: apache#13360


Describe the bug
Produce chunk messages failed when topic level maxMessageSize is set.
See details in the following unit test case.

To Reproduce
See this new unit test code in org.apache.pulsar.broker.admin.TopicPoliciesTest

   @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);
   }
       producer.send(data);
   }

Expected behavior
Chunking should work fine if we change maxMessageSize.

Screenshots
NA

Desktop (please complete the following information):

  • OS: macOS

Additional context
NA

@sijie sijie added the type/bug label Dec 16, 2021
@github-actions
Copy link

The issue had no activity for 30 days, mark with Stale label.

@github-actions github-actions bot added the Stale label Feb 26, 2022
@sijie sijie closed this as completed Feb 26, 2022
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Projects
None yet
Development

No branches or pull requests

1 participant