rdhabalia commented on a change in pull request #11671:
URL: https://github.com/apache/pulsar/pull/11671#discussion_r689722778
##########
File path:
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
##########
@@ -1211,5 +1218,45 @@ public void
testProducerExceptionAndThenUnblockTimeQuota() throws Exception {
client.close();
}
+ @Test(dataProvider = "backlogQuotaSizeGB")
+ public void testBacklogQuotaInGB(boolean backlogQuotaSizeGB) throws
Exception {
+
+ pulsar.close();
+ long backlogQuotaByte = 10 * 1024;
+ if (backlogQuotaSizeGB) {
+ config.setBacklogQuotaDefaultLimitGB(((double) backlogQuotaByte) /
BacklogQuotaImpl.BYTES_IN_GIGABYTE);
+ } else {
+ config.setBacklogQuotaDefaultLimitByte(backlogQuotaByte);
+ }
+
config.setBacklogQuotaDefaultRetentionPolicy(BacklogQuota.RetentionPolicy.consumer_backlog_eviction);
+ pulsar = new PulsarService(config);
+ pulsar.start();
+
+ @Cleanup
+ PulsarClient client =
PulsarClient.builder().serviceUrl(pulsar.getBrokerServiceUrl()).statsInterval(0,
TimeUnit.SECONDS)
+ .build();
+
+ final String topic1 = "persistent://prop/ns-quota/topic2";
+ final String subName1 = "c1";
+ final String subName2 = "c2";
+ final int numMsgs = 20;
+
+ Consumer<byte[]> consumer1 =
client.newConsumer().topic(topic1).subscriptionName(subName1).subscribe();
+ Consumer<byte[]> consumer2 =
client.newConsumer().topic(topic1).subscriptionName(subName2).subscribe();
+ org.apache.pulsar.client.api.Producer<byte[]> producer =
createProducer(client, topic1);
+ byte[] content = new byte[1024];
+ for (int i = 0; i < numMsgs; i++) {
+ producer.send(content);
+ consumer1.receive();
+ consumer2.receive();
+ }
+
+ Thread.sleep((TIME_TO_CHECK_BACKLOG_QUOTA + 1) * 1000);
+ rolloverStats();
+
+ TopicStats stats = admin.topics().getStats(topic1);
+ assertTrue(stats.getBacklogSize() < 10 * 1024, "Storage size is [" +
stats.getStorageSize() + "]");
+ System.out.println("finish");
Review comment:
oops. I missed removing it after the testing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
