This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 825b862d867 [cleanup] remove unused config
messagePublishBufferCheckIntervalInMillis (#24252)
825b862d867 is described below
commit 825b862d8674f32ffbc13f10c17611ba394bfcc9
Author: 道君- Tao Jiuming <[email protected]>
AuthorDate: Tue May 6 14:57:31 2025 +0800
[cleanup] remove unused config messagePublishBufferCheckIntervalInMillis
(#24252)
---
deployment/terraform-ansible/templates/broker.conf | 4 ----
.../main/java/org/apache/pulsar/broker/ServiceConfiguration.java | 7 -------
2 files changed, 11 deletions(-)
diff --git a/deployment/terraform-ansible/templates/broker.conf
b/deployment/terraform-ansible/templates/broker.conf
index bae55cb69f1..7b9c5a84cf2 100644
--- a/deployment/terraform-ansible/templates/broker.conf
+++ b/deployment/terraform-ansible/templates/broker.conf
@@ -410,10 +410,6 @@ replicatedSubscriptionsSnapshotMaxCachedPerSubscription=10
# Use -1 to disable the memory limitation. Default is 1/2 of direct memory.
maxMessagePublishBufferSizeInMB=
-# Interval between checks to see if message publish buffer size is exceed the
max message publish buffer size
-# Use 0 or negative number to disable the max publish buffer limiting.
-messagePublishBufferCheckIntervalInMillis=100
-
# Check between intervals to see if consumed ledgers need to be trimmed
# Use 0 or negative number to disable the check
retentionCheckIntervalInSeconds=120
diff --git
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
index f2ab111bb84..4ba7058aeaa 100644
---
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
+++
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
@@ -1474,13 +1474,6 @@ public class ServiceConfiguration implements
PulsarConfiguration {
private int maxMessagePublishBufferSizeInMB = Math.max(64,
(int) (DirectMemoryUtils.jvmMaxDirectMemory() / 2 / (1024 * 1024)));
- @FieldContext(
- category = CATEGORY_SERVER,
- doc = "Interval between checks to see if message publish buffer size
is exceed the max message publish "
- + "buffer size"
- )
- private int messagePublishBufferCheckIntervalInMillis = 100;
-
@FieldContext(category = CATEGORY_SERVER, doc = "Whether to recover
cursors lazily when trying to recover a "
+ "managed ledger backing a persistent topic. It can improve write
availability of topics.\n"
+ "The caveat is now when recovered ledger is ready to write we're
not sure if all old consumers last mark "
