diff --git a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java index 0d248c4e170..6558b471bd7 100644 --- a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java +++ b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java @@ -266,6 +266,8 @@ public class BrokerConfig extends BrokerIdentity { @ImportantField private long transactionCheckInterval = 30 * 1000; + private long transactionMetricFlushInterval = 3 * 1000; + /** * transaction batch op message */ @@ -1755,4 +1757,12 @@ public int getSplitRegistrationSize() { public void setSplitRegistrationSize(int splitRegistrationSize) { this.splitRegistrationSize = splitRegistrationSize; } + + public long getTransactionMetricFlushInterval() { + return transactionMetricFlushInterval; + } + + public void setTransactionMetricFlushInterval(long transactionMetricFlushInterval) { + this.transactionMetricFlushInterval = transactionMetricFlushInterval; + } }