merlimat closed pull request #3101: [conf] Clean up ServiceConfiguration to use
lombok getter and setter
URL: https://github.com/apache/pulsar/pull/3101
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
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 9eba00e893..34882bd16c 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
@@ -18,24 +18,27 @@
*/
package org.apache.pulsar.broker;
+
+import com.google.common.collect.Sets;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.Properties;
import java.util.Set;
import java.util.concurrent.TimeUnit;
-
+import lombok.Getter;
+import lombok.Setter;
import org.apache.bookkeeper.client.api.DigestType;
import org.apache.pulsar.broker.authorization.PulsarAuthorizationProvider;
import org.apache.pulsar.common.configuration.FieldContext;
import org.apache.pulsar.common.configuration.PulsarConfiguration;
-
-import com.google.common.collect.Sets;
import org.apache.pulsar.common.policies.data.BacklogQuota;
/**
* Pulsar service configuration object.
*/
+@Getter
+@Setter
public class ServiceConfiguration implements PulsarConfiguration {
/***** --- pulsar configuration --- ****/
@@ -511,7 +514,7 @@
// If true, export publisher stats when returning topics stats from the
admin rest api
private boolean exposePublisherStats = true;
private int statsUpdateFrequencyInSecs = 60;
- private int statsUpdateInitailDelayInSecs = 60;
+ private int statsUpdateInitialDelayInSecs = 60;
/**** --- Ledger Offloading --- ****/
/****
@@ -527,14 +530,6 @@
// Maximum number of thread pool threads for ledger offloading
private int managedLedgerOffloadMaxThreads = 2;
- public String getZookeeperServers() {
- return zookeeperServers;
- }
-
- public void setZookeeperServers(String zookeeperServers) {
- this.zookeeperServers = zookeeperServers;
- }
-
/**
* @deprecated See {@link #getConfigurationStoreServers}
*/
@@ -568,1275 +563,26 @@ public void setConfigurationStoreServers(String
configurationStoreServers) {
this.configurationStoreServers = configurationStoreServers;
}
- public int getBrokerServicePort() {
- return brokerServicePort;
- }
-
- public void setBrokerServicePort(int brokerServicePort) {
- this.brokerServicePort = brokerServicePort;
- }
-
- public int getBrokerServicePortTls() {
- return brokerServicePortTls;
- }
-
- public void setBrokerServicePortTls(int brokerServicePortTls) {
- this.brokerServicePortTls = brokerServicePortTls;
- }
-
- public int getWebServicePort() {
- return webServicePort;
- }
-
- public void setWebServicePort(int webServicePort) {
- this.webServicePort = webServicePort;
- }
-
- public int getWebServicePortTls() {
- return webServicePortTls;
- }
-
- public void setWebServicePortTls(int webServicePortTls) {
- this.webServicePortTls = webServicePortTls;
- }
-
- public String getBindAddress() {
- return this.bindAddress;
- }
-
- public void setBindAddress(String bindAddress) {
- this.bindAddress = bindAddress;
- }
-
- public String getAdvertisedAddress() {
- return this.advertisedAddress;
- }
-
- public void setAdvertisedAddress(String advertisedAddress) {
- this.advertisedAddress = advertisedAddress;
- }
-
- public int getNumIOThreads() {
- return numIOThreads;
- }
-
- public void setNumIOThreads(int numIOThreads) {
- this.numIOThreads = numIOThreads;
- }
-
- public boolean isWebSocketServiceEnabled() {
- return webSocketServiceEnabled;
- }
-
- public void setWebSocketServiceEnabled(boolean webSocketServiceEnabled) {
- this.webSocketServiceEnabled = webSocketServiceEnabled;
- }
-
- public String getClusterName() {
- return clusterName;
- }
-
- public void setClusterName(String clusterName) {
- this.clusterName = clusterName;
- }
-
- public boolean isFailureDomainsEnabled() {
- return failureDomainsEnabled;
- }
-
- public void setFailureDomainsEnabled(boolean failureDomainsEnabled) {
- this.failureDomainsEnabled = failureDomainsEnabled;
- }
-
- public long getBrokerShutdownTimeoutMs() {
- return brokerShutdownTimeoutMs;
- }
-
- public void setBrokerShutdownTimeoutMs(long brokerShutdownTimeoutMs) {
- this.brokerShutdownTimeoutMs = brokerShutdownTimeoutMs;
- }
-
- public boolean isBacklogQuotaCheckEnabled() {
- return backlogQuotaCheckEnabled;
- }
-
- public void setBacklogQuotaCheckEnabled(boolean backlogQuotaCheckEnabled) {
- this.backlogQuotaCheckEnabled = backlogQuotaCheckEnabled;
- }
-
- public int getBacklogQuotaCheckIntervalInSeconds() {
- return backlogQuotaCheckIntervalInSeconds;
- }
-
- public void setBacklogQuotaCheckIntervalInSeconds(int
backlogQuotaCheckIntervalInSeconds) {
- this.backlogQuotaCheckIntervalInSeconds =
backlogQuotaCheckIntervalInSeconds;
- }
-
- public long getBacklogQuotaDefaultLimitGB() {
- return backlogQuotaDefaultLimitGB;
- }
-
- public void setBacklogQuotaDefaultLimitGB(long backlogQuotaDefaultLimitGB)
{
- this.backlogQuotaDefaultLimitGB = backlogQuotaDefaultLimitGB;
- }
-
- public boolean isBrokerDeleteInactiveTopicsEnabled() {
- return brokerDeleteInactiveTopicsEnabled;
- }
-
- public void setBrokerDeleteInactiveTopicsEnabled(boolean
brokerDeleteInactiveTopicsEnabled) {
- this.brokerDeleteInactiveTopicsEnabled =
brokerDeleteInactiveTopicsEnabled;
- }
-
- public int getBrokerDeduplicationMaxNumberOfProducers() {
- return brokerDeduplicationMaxNumberOfProducers;
- }
-
- public void setBrokerDeduplicationMaxNumberOfProducers(int
brokerDeduplicationMaxNumberOfProducers) {
- this.brokerDeduplicationMaxNumberOfProducers =
brokerDeduplicationMaxNumberOfProducers;
- }
-
- public int getBrokerDeduplicationEntriesInterval() {
- return brokerDeduplicationEntriesInterval;
- }
-
- public void setBrokerDeduplicationEntriesInterval(int
brokerDeduplicationEntriesInterval) {
- this.brokerDeduplicationEntriesInterval =
brokerDeduplicationEntriesInterval;
- }
-
- public int getBrokerDeduplicationProducerInactivityTimeoutMinutes() {
- return brokerDeduplicationProducerInactivityTimeoutMinutes;
- }
-
- public void setBrokerDeduplicationProducerInactivityTimeoutMinutes(
- int brokerDeduplicationProducerInactivityTimeoutMinutes) {
- this.brokerDeduplicationProducerInactivityTimeoutMinutes =
brokerDeduplicationProducerInactivityTimeoutMinutes;
- }
-
- public int getDefaultNumberOfNamespaceBundles() {
- return defaultNumberOfNamespaceBundles;
- }
-
- public void setDefaultNumberOfNamespaceBundles(int
defaultNumberOfNamespaceBundles) {
- this.defaultNumberOfNamespaceBundles = defaultNumberOfNamespaceBundles;
- }
-
- public long getBrokerDeleteInactiveTopicsFrequencySeconds() {
- return brokerDeleteInactiveTopicsFrequencySeconds;
- }
-
- public void setBrokerDeleteInactiveTopicsFrequencySeconds(long
brokerDeleteInactiveTopicsFrequencySeconds) {
- this.brokerDeleteInactiveTopicsFrequencySeconds =
brokerDeleteInactiveTopicsFrequencySeconds;
- }
-
- public int getMessageExpiryCheckIntervalInMinutes() {
- return messageExpiryCheckIntervalInMinutes;
- }
-
- public void setMessageExpiryCheckIntervalInMinutes(int
messageExpiryCheckIntervalInMinutes) {
- this.messageExpiryCheckIntervalInMinutes =
messageExpiryCheckIntervalInMinutes;
- }
-
- public boolean isBrokerDeduplicationEnabled() {
- return brokerDeduplicationEnabled;
- }
-
- public void setBrokerDeduplicationEnabled(boolean
brokerDeduplicationEnabled) {
- this.brokerDeduplicationEnabled = brokerDeduplicationEnabled;
- }
-
- public int getActiveConsumerFailoverDelayTimeMillis() {
- return activeConsumerFailoverDelayTimeMillis;
- }
-
- public void setActiveConsumerFailoverDelayTimeMillis(int
activeConsumerFailoverDelayTimeMillis) {
- this.activeConsumerFailoverDelayTimeMillis =
activeConsumerFailoverDelayTimeMillis;
- }
-
- public long getSubscriptionExpirationTimeMinutes() {
- return subscriptionExpirationTimeMinutes;
- }
-
- public void setSubscriptionExpirationTimeMinutes(long
subscriptionExpirationTimeMinutes) {
- this.subscriptionExpirationTimeMinutes =
subscriptionExpirationTimeMinutes;
- }
-
- public long getSubscriptionExpiryCheckIntervalInMinutes() {
- return subscriptionExpiryCheckIntervalInMinutes;
- }
-
- public void setSubscriptionExpiryCheckIntervalInMinutes(long
subscriptionExpiryCheckIntervalInMinutes) {
- this.subscriptionExpiryCheckIntervalInMinutes =
subscriptionExpiryCheckIntervalInMinutes;
- }
-
- public boolean isClientLibraryVersionCheckEnabled() {
- return clientLibraryVersionCheckEnabled;
- }
-
- public void setClientLibraryVersionCheckEnabled(boolean
clientLibraryVersionCheckEnabled) {
- this.clientLibraryVersionCheckEnabled =
clientLibraryVersionCheckEnabled;
- }
-
- public String getStatusFilePath() {
- return statusFilePath;
- }
-
- public void setStatusFilePath(String statusFilePath) {
- this.statusFilePath = statusFilePath;
- }
-
- public int getMaxUnackedMessagesPerConsumer() {
- return maxUnackedMessagesPerConsumer;
- }
-
- public void setMaxUnackedMessagesPerConsumer(int
maxUnackedMessagesPerConsumer) {
- this.maxUnackedMessagesPerConsumer = maxUnackedMessagesPerConsumer;
- }
-
- public int getMaxUnackedMessagesPerSubscription() {
- return maxUnackedMessagesPerSubscription;
- }
-
- public void setMaxUnackedMessagesPerSubscription(int
maxUnackedMessagesPerSubscription) {
- this.maxUnackedMessagesPerSubscription =
maxUnackedMessagesPerSubscription;
- }
-
- public int getMaxUnackedMessagesPerBroker() {
- return maxUnackedMessagesPerBroker;
- }
-
- public void setMaxUnackedMessagesPerBroker(int
maxUnackedMessagesPerBroker) {
- this.maxUnackedMessagesPerBroker = maxUnackedMessagesPerBroker;
- }
-
- public double getMaxUnackedMessagesPerSubscriptionOnBrokerBlocked() {
- return maxUnackedMessagesPerSubscriptionOnBrokerBlocked;
- }
-
- public void setMaxUnackedMessagesPerSubscriptionOnBrokerBlocked(
- double maxUnackedMessagesPerSubscriptionOnBrokerBlocked) {
- this.maxUnackedMessagesPerSubscriptionOnBrokerBlocked =
maxUnackedMessagesPerSubscriptionOnBrokerBlocked;
- }
-
- public int getDispatchThrottlingRatePerTopicInMsg() {
- return dispatchThrottlingRatePerTopicInMsg;
- }
-
- public void setDispatchThrottlingRatePerTopicInMsg(int
dispatchThrottlingRatePerTopicInMsg) {
- this.dispatchThrottlingRatePerTopicInMsg =
dispatchThrottlingRatePerTopicInMsg;
- }
-
- public long getDispatchThrottlingRatePerTopicInByte() {
- return dispatchThrottlingRatePerTopicInByte;
- }
-
- public void setDispatchThrottlingRatePerTopicInByte(long
dispatchThrottlingRatePerTopicInByte) {
- this.dispatchThrottlingRatePerTopicInByte =
dispatchThrottlingRatePerTopicInByte;
- }
-
- public int getDispatchThrottlingRatePerSubscriptionInMsg() {
- return dispatchThrottlingRatePerSubscriptionInMsg;
- }
-
- public void setDispatchThrottlingRatePerSubscriptionInMsg(int
dispatchThrottlingRatePerSubscriptionInMsg) {
- this.dispatchThrottlingRatePerSubscriptionInMsg =
dispatchThrottlingRatePerSubscriptionInMsg;
- }
-
- public long getDispatchThrottlingRatePerSubscribeInByte() {
- return dispatchThrottlingRatePerSubscribeInByte;
- }
-
- public void setDispatchThrottlingRatePerSubscribeInByte(long
dispatchThrottlingRatePerSubscribeInByte) {
- this.dispatchThrottlingRatePerSubscribeInByte =
dispatchThrottlingRatePerSubscribeInByte;
- }
-
- public boolean isDispatchThrottlingOnNonBacklogConsumerEnabled() {
- return dispatchThrottlingOnNonBacklogConsumerEnabled;
- }
-
- public void setDispatchThrottlingOnNonBacklogConsumerEnabled(boolean
dispatchThrottlingOnNonBacklogConsumerEnabled) {
- this.dispatchThrottlingOnNonBacklogConsumerEnabled =
dispatchThrottlingOnNonBacklogConsumerEnabled;
- }
-
- public int getMaxConcurrentLookupRequest() {
- return maxConcurrentLookupRequest;
- }
-
- public void setMaxConcurrentLookupRequest(int maxConcurrentLookupRequest) {
- this.maxConcurrentLookupRequest = maxConcurrentLookupRequest;
- }
-
- public int getMaxConcurrentTopicLoadRequest() {
- return maxConcurrentTopicLoadRequest;
- }
-
- public void setMaxConcurrentTopicLoadRequest(int
maxConcurrentTopicLoadRequest) {
- this.maxConcurrentTopicLoadRequest = maxConcurrentTopicLoadRequest;
- }
-
- public int getMaxConcurrentNonPersistentMessagePerConnection() {
- return maxConcurrentNonPersistentMessagePerConnection;
- }
-
- public void setMaxConcurrentNonPersistentMessagePerConnection(int
maxConcurrentNonPersistentMessagePerConnection) {
- this.maxConcurrentNonPersistentMessagePerConnection =
maxConcurrentNonPersistentMessagePerConnection;
- }
-
- public int getNumWorkerThreadsForNonPersistentTopic() {
- return numWorkerThreadsForNonPersistentTopic;
- }
-
- public void setNumWorkerThreadsForNonPersistentTopic(int
numWorkerThreadsForNonPersistentTopic) {
- this.numWorkerThreadsForNonPersistentTopic =
numWorkerThreadsForNonPersistentTopic;
- }
-
- public boolean isEnablePersistentTopics() {
- return enablePersistentTopics;
- }
-
- public void setEnablePersistentTopics(boolean enablePersistentTopics) {
- this.enablePersistentTopics = enablePersistentTopics;
- }
-
- public boolean isEnableNonPersistentTopics() {
- return enableNonPersistentTopics;
- }
-
- public void setEnableNonPersistentTopics(boolean
enableNonPersistentTopics) {
- this.enableNonPersistentTopics = enableNonPersistentTopics;
- }
-
- public boolean isEnableRunBookieTogether() {
- return enableRunBookieTogether;
- }
-
- public void setEnableRunBookieTogether(boolean enableRunBookieTogether) {
- this.enableRunBookieTogether = enableRunBookieTogether;
- }
-
- public boolean isEnableRunBookieAutoRecoveryTogether() {
- return enableRunBookieAutoRecoveryTogether;
- }
-
- public void setEnableRunBookieAutoRecoveryTogether(boolean
enableRunBookieAutoRecoveryTogether) {
- this.enableRunBookieAutoRecoveryTogether =
enableRunBookieAutoRecoveryTogether;
- }
-
- public int getMaxProducersPerTopic() {
- return maxProducersPerTopic;
- }
-
- public void setMaxProducersPerTopic(int maxProducersPerTopic) {
- this.maxProducersPerTopic = maxProducersPerTopic;
- }
-
- public int getMaxConsumersPerTopic() {
- return maxConsumersPerTopic;
- }
-
- public void setMaxConsumersPerTopic(int maxConsumersPerTopic) {
- this.maxConsumersPerTopic = maxConsumersPerTopic;
- }
-
- public int getMaxConsumersPerSubscription() {
- return maxConsumersPerSubscription;
- }
-
- public void setMaxConsumersPerSubscription(int
maxConsumersPerSubscription) {
- this.maxConsumersPerSubscription = maxConsumersPerSubscription;
- }
-
- public boolean isTlsEnabled() {
- return tlsEnabled;
- }
-
- public void setTlsEnabled(boolean tlsEnabled) {
- this.tlsEnabled = tlsEnabled;
- }
-
- public String getTlsCertificateFilePath() {
- return tlsCertificateFilePath;
- }
-
- public void setTlsCertificateFilePath(String tlsCertificateFilePath) {
- this.tlsCertificateFilePath = tlsCertificateFilePath;
- }
-
- public String getTlsKeyFilePath() {
- return tlsKeyFilePath;
- }
-
- public void setTlsKeyFilePath(String tlsKeyFilePath) {
- this.tlsKeyFilePath = tlsKeyFilePath;
- }
-
- public String getTlsTrustCertsFilePath() {
- return tlsTrustCertsFilePath;
- }
-
- public void setTlsTrustCertsFilePath(String tlsTrustCertsFilePath) {
- this.tlsTrustCertsFilePath = tlsTrustCertsFilePath;
- }
-
- public boolean isTlsAllowInsecureConnection() {
- return tlsAllowInsecureConnection;
- }
-
- public void setTlsAllowInsecureConnection(boolean
tlsAllowInsecureConnection) {
- this.tlsAllowInsecureConnection = tlsAllowInsecureConnection;
- }
-
- public boolean isAuthenticationEnabled() {
- return authenticationEnabled;
- }
-
- public void setAuthenticationEnabled(boolean authenticationEnabled) {
- this.authenticationEnabled = authenticationEnabled;
- }
-
- public String getAuthorizationProvider() {
- return authorizationProvider;
- }
-
- public void setAuthorizationProvider(String authorizationProvider) {
- this.authorizationProvider = authorizationProvider;
- }
-
- public void setAuthenticationProviders(Set<String> providersClassNames) {
- authenticationProviders = providersClassNames;
- }
-
- public Set<String> getAuthenticationProviders() {
- return authenticationProviders;
- }
-
- public boolean isAuthorizationEnabled() {
- return authorizationEnabled;
- }
-
- public void setAuthorizationEnabled(boolean authorizationEnabled) {
- this.authorizationEnabled = authorizationEnabled;
- }
-
- public Set<String> getSuperUserRoles() {
- return superUserRoles;
- }
-
- public Set<String> getProxyRoles() {
- return proxyRoles;
- }
-
- public void setProxyRoles(Set<String> proxyRoles) {
- this.proxyRoles = proxyRoles;
- }
-
- public boolean getAuthorizationAllowWildcardsMatching() {
- return authorizationAllowWildcardsMatching;
- }
-
- public void setAuthorizationAllowWildcardsMatching(boolean
authorizationAllowWildcardsMatching) {
- this.authorizationAllowWildcardsMatching =
authorizationAllowWildcardsMatching;
- }
-
- public void setSuperUserRoles(Set<String> superUserRoles) {
- this.superUserRoles = superUserRoles;
+ public Object getProperty(String key) {
+ return properties.get(key);
}
- public String getBrokerClientAuthenticationPlugin() {
- return brokerClientAuthenticationPlugin;
+ @Override
+ public Properties getProperties() {
+ return properties;
}
- public void setBrokerClientAuthenticationPlugin(String
brokerClientAuthenticationPlugin) {
- this.brokerClientAuthenticationPlugin =
brokerClientAuthenticationPlugin;
+ @Override
+ public void setProperties(Properties properties) {
+ this.properties = properties;
}
- public String getBrokerClientAuthenticationParameters() {
- return brokerClientAuthenticationParameters;
+ public Optional<Double> getLoadBalancerOverrideBrokerNicSpeedGbps() {
+ return Optional.ofNullable(loadBalancerOverrideBrokerNicSpeedGbps);
}
- public void setBrokerClientAuthenticationParameters(String
brokerClientAuthenticationParameters) {
- this.brokerClientAuthenticationParameters =
brokerClientAuthenticationParameters;
+ public int getBookkeeperHealthCheckIntervalSec() {
+ return (int) bookkeeperClientHealthCheckIntervalSeconds;
}
- public String getBrokerClientTrustCertsFilePath() {
- return brokerClientTrustCertsFilePath;
- }
-
- public void setBrokerClientTrustCertsFilePath(String
brokerClientTrustCertsFilePath) {
- this.brokerClientTrustCertsFilePath = brokerClientTrustCertsFilePath;
- }
-
- public String getAnonymousUserRole() {
- return anonymousUserRole;
- }
-
- public void setAnonymousUserRole(String anonymousUserRole) {
- this.anonymousUserRole = anonymousUserRole;
- }
-
- public String getBookkeeperClientAuthenticationPlugin() {
- return bookkeeperClientAuthenticationPlugin;
- }
-
- public void setBookkeeperClientAuthenticationPlugin(String
bookkeeperClientAuthenticationPlugin) {
- this.bookkeeperClientAuthenticationPlugin =
bookkeeperClientAuthenticationPlugin;
- }
-
- public String getBookkeeperClientAuthenticationParametersName() {
- return bookkeeperClientAuthenticationParametersName;
- }
-
- public void setBookkeeperClientAuthenticationParametersName(String
bookkeeperClientAuthenticationParametersName) {
- this.bookkeeperClientAuthenticationParametersName =
bookkeeperClientAuthenticationParametersName;
- }
-
- public String getBookkeeperClientAuthenticationParameters() {
- return bookkeeperClientAuthenticationParameters;
- }
-
- public void setBookkeeperClientAuthenticationParameters(String
bookkeeperClientAuthenticationParameters) {
- this.bookkeeperClientAuthenticationParameters =
bookkeeperClientAuthenticationParameters;
- }
-
- public long getBookkeeperClientTimeoutInSeconds() {
- return bookkeeperClientTimeoutInSeconds;
- }
-
- public void setBookkeeperClientTimeoutInSeconds(long
bookkeeperClientTimeoutInSeconds) {
- this.bookkeeperClientTimeoutInSeconds =
bookkeeperClientTimeoutInSeconds;
- }
-
- public int getBookkeeperClientSpeculativeReadTimeoutInMillis() {
- return bookkeeperClientSpeculativeReadTimeoutInMillis;
- }
-
- public void setBookkeeperClientSpeculativeReadTimeoutInMillis(int
bookkeeperClientSpeculativeReadTimeoutInMillis) {
- this.bookkeeperClientSpeculativeReadTimeoutInMillis =
bookkeeperClientSpeculativeReadTimeoutInMillis;
- }
-
- public boolean isBookkeeperUseV2WireProtocol() {
- return bookkeeperUseV2WireProtocol;
- }
-
- public void setBookkeeperUseV2WireProtocol(boolean
bookkeeperUseV2WireProtocol) {
- this.bookkeeperUseV2WireProtocol = bookkeeperUseV2WireProtocol;
- }
-
- public boolean isBookkeeperClientHealthCheckEnabled() {
- return bookkeeperClientHealthCheckEnabled;
- }
-
- public void setBookkeeperClientHealthCheckEnabled(boolean
bookkeeperClientHealthCheckEnabled) {
- this.bookkeeperClientHealthCheckEnabled =
bookkeeperClientHealthCheckEnabled;
- }
-
- public long getBookkeeperClientHealthCheckIntervalSeconds() {
- return bookkeeperClientHealthCheckIntervalSeconds;
- }
-
- public void setBookkeeperClientHealthCheckIntervalSeconds(long
bookkeeperClientHealthCheckIntervalSeconds) {
- this.bookkeeperClientHealthCheckIntervalSeconds =
bookkeeperClientHealthCheckIntervalSeconds;
- }
-
- public long getBookkeeperClientHealthCheckErrorThresholdPerInterval() {
- return bookkeeperClientHealthCheckErrorThresholdPerInterval;
- }
-
- public void setBookkeeperClientHealthCheckErrorThresholdPerInterval(
- long bookkeeperClientHealthCheckErrorThresholdPerInterval) {
- this.bookkeeperClientHealthCheckErrorThresholdPerInterval =
bookkeeperClientHealthCheckErrorThresholdPerInterval;
- }
-
- public long getBookkeeperClientHealthCheckQuarantineTimeInSeconds() {
- return bookkeeperClientHealthCheckQuarantineTimeInSeconds;
- }
-
- public void setBookkeeperClientHealthCheckQuarantineTimeInSeconds(
- long bookkeeperClientHealthCheckQuarantineTimeInSeconds) {
- this.bookkeeperClientHealthCheckQuarantineTimeInSeconds =
bookkeeperClientHealthCheckQuarantineTimeInSeconds;
- }
-
- public boolean isBookkeeperClientRackawarePolicyEnabled() {
- return bookkeeperClientRackawarePolicyEnabled;
- }
-
- public void setBookkeeperClientRackawarePolicyEnabled(boolean
bookkeeperClientRackawarePolicyEnabled) {
- this.bookkeeperClientRackawarePolicyEnabled =
bookkeeperClientRackawarePolicyEnabled;
- }
-
- public String getBookkeeperClientIsolationGroups() {
- return bookkeeperClientIsolationGroups;
- }
-
- public void setBookkeeperClientIsolationGroups(String
bookkeeperClientIsolationGroups) {
- this.bookkeeperClientIsolationGroups = bookkeeperClientIsolationGroups;
- }
-
- public int getManagedLedgerDefaultEnsembleSize() {
- return managedLedgerDefaultEnsembleSize;
- }
-
- public void setManagedLedgerDefaultEnsembleSize(int
managedLedgerDefaultEnsembleSize) {
- this.managedLedgerDefaultEnsembleSize =
managedLedgerDefaultEnsembleSize;
- }
-
- public int getManagedLedgerDefaultWriteQuorum() {
- return managedLedgerDefaultWriteQuorum;
- }
-
- public void setManagedLedgerDefaultWriteQuorum(int
managedLedgerDefaultWriteQuorum) {
- this.managedLedgerDefaultWriteQuorum = managedLedgerDefaultWriteQuorum;
- }
-
- public int getManagedLedgerDefaultAckQuorum() {
- return managedLedgerDefaultAckQuorum;
- }
-
- public void setManagedLedgerDefaultAckQuorum(int
managedLedgerDefaultAckQuorum) {
- this.managedLedgerDefaultAckQuorum = managedLedgerDefaultAckQuorum;
- }
-
- public DigestType getManagedLedgerDigestType() {
- return managedLedgerDigestType;
- }
-
- public void setManagedLedgerDigestType(DigestType managedLedgerDigestType)
{
- this.managedLedgerDigestType = managedLedgerDigestType;
- }
-
- public int getManagedLedgerMaxEnsembleSize() {
- return managedLedgerMaxEnsembleSize;
- }
-
- public void setManagedLedgerMaxEnsembleSize(int
managedLedgerMaxEnsembleSize) {
- this.managedLedgerMaxEnsembleSize = managedLedgerMaxEnsembleSize;
- }
-
- public int getManagedLedgerMaxWriteQuorum() {
- return managedLedgerMaxWriteQuorum;
- }
-
- public void setManagedLedgerMaxWriteQuorum(int
managedLedgerMaxWriteQuorum) {
- this.managedLedgerMaxWriteQuorum = managedLedgerMaxWriteQuorum;
- }
-
- public int getManagedLedgerMaxAckQuorum() {
- return managedLedgerMaxAckQuorum;
- }
-
- public void setManagedLedgerMaxAckQuorum(int managedLedgerMaxAckQuorum) {
- this.managedLedgerMaxAckQuorum = managedLedgerMaxAckQuorum;
- }
-
- public int getManagedLedgerCacheSizeMB() {
- return managedLedgerCacheSizeMB;
- }
-
- public void setManagedLedgerCacheSizeMB(int managedLedgerCacheSizeMB) {
- this.managedLedgerCacheSizeMB = managedLedgerCacheSizeMB;
- }
-
- public double getManagedLedgerCacheEvictionWatermark() {
- return managedLedgerCacheEvictionWatermark;
- }
-
- public void setManagedLedgerCacheEvictionWatermark(double
managedLedgerCacheEvictionWatermark) {
- this.managedLedgerCacheEvictionWatermark =
managedLedgerCacheEvictionWatermark;
- }
-
- public double getManagedLedgerDefaultMarkDeleteRateLimit() {
- return managedLedgerDefaultMarkDeleteRateLimit;
- }
-
- public void setManagedLedgerDefaultMarkDeleteRateLimit(double
managedLedgerDefaultMarkDeleteRateLimit) {
- this.managedLedgerDefaultMarkDeleteRateLimit =
managedLedgerDefaultMarkDeleteRateLimit;
- }
-
- public int getManagedLedgerMaxEntriesPerLedger() {
- return managedLedgerMaxEntriesPerLedger;
- }
-
- public void setManagedLedgerMaxEntriesPerLedger(int
managedLedgerMaxEntriesPerLedger) {
- this.managedLedgerMaxEntriesPerLedger =
managedLedgerMaxEntriesPerLedger;
- }
-
- public int getManagedLedgerMinLedgerRolloverTimeMinutes() {
- return managedLedgerMinLedgerRolloverTimeMinutes;
- }
-
- public void setManagedLedgerMinLedgerRolloverTimeMinutes(int
managedLedgerMinLedgerRolloverTimeMinutes) {
- this.managedLedgerMinLedgerRolloverTimeMinutes =
managedLedgerMinLedgerRolloverTimeMinutes;
- }
-
- public int getManagedLedgerMaxLedgerRolloverTimeMinutes() {
- return managedLedgerMaxLedgerRolloverTimeMinutes;
- }
-
- public void setManagedLedgerMaxLedgerRolloverTimeMinutes(int
managedLedgerMaxLedgerRolloverTimeMinutes) {
- this.managedLedgerMaxLedgerRolloverTimeMinutes =
managedLedgerMaxLedgerRolloverTimeMinutes;
- }
-
- public long getManagedLedgerOffloadDeletionLagMs() {
- return managedLedgerOffloadDeletionLagMs;
- }
-
- public void setManagedLedgerOffloadDeletionLag(long amount, TimeUnit unit)
{
- this.managedLedgerOffloadDeletionLagMs = unit.toMillis(amount);
- }
-
- public int getManagedLedgerCursorMaxEntriesPerLedger() {
- return managedLedgerCursorMaxEntriesPerLedger;
- }
-
- public void setManagedLedgerCursorMaxEntriesPerLedger(int
managedLedgerCursorMaxEntriesPerLedger) {
- this.managedLedgerCursorMaxEntriesPerLedger =
managedLedgerCursorMaxEntriesPerLedger;
- }
-
- public int getManagedLedgerCursorRolloverTimeInSeconds() {
- return managedLedgerCursorRolloverTimeInSeconds;
- }
-
- public void setManagedLedgerCursorRolloverTimeInSeconds(int
managedLedgerCursorRolloverTimeInSeconds) {
- this.managedLedgerCursorRolloverTimeInSeconds =
managedLedgerCursorRolloverTimeInSeconds;
- }
-
- public int getManagedLedgerMaxUnackedRangesToPersist() {
- return managedLedgerMaxUnackedRangesToPersist;
- }
-
- public void setManagedLedgerMaxUnackedRangesToPersist(int
managedLedgerMaxUnackedRangesToPersist) {
- this.managedLedgerMaxUnackedRangesToPersist =
managedLedgerMaxUnackedRangesToPersist;
- }
-
- public int getManagedLedgerMaxUnackedRangesToPersistInZooKeeper() {
- return managedLedgerMaxUnackedRangesToPersistInZooKeeper;
- }
-
- public void setManagedLedgerMaxUnackedRangesToPersistInZooKeeper(
- int managedLedgerMaxUnackedRangesToPersistInZookeeper) {
- this.managedLedgerMaxUnackedRangesToPersistInZooKeeper =
managedLedgerMaxUnackedRangesToPersistInZookeeper;
- }
-
- public int getManagedLedgerNumWorkerThreads() {
- return managedLedgerNumWorkerThreads;
- }
-
- public void setManagedLedgerNumWorkerThreads(int
managedLedgerNumWorkerThreads) {
- this.managedLedgerNumWorkerThreads = managedLedgerNumWorkerThreads;
- }
-
- public int getManagedLedgerNumSchedulerThreads() {
- return managedLedgerNumSchedulerThreads;
- }
-
- public void setManagedLedgerNumSchedulerThreads(int
managedLedgerNumSchedulerThreads) {
- this.managedLedgerNumSchedulerThreads =
managedLedgerNumSchedulerThreads;
- }
-
- public boolean isAutoSkipNonRecoverableData() {
- return autoSkipNonRecoverableData;
- }
-
- public void setAutoSkipNonRecoverableData(boolean
skipNonRecoverableLedger) {
- this.autoSkipNonRecoverableData = skipNonRecoverableLedger;
- }
-
- public long getManagedLedgerMetadataOperationsTimeoutSeconds() {
- return managedLedgerMetadataOperationsTimeoutSeconds;
- }
-
- public void setManagedLedgerMetadataOperationsTimeoutSeconds(long
managedLedgerMetadataOperationsTimeoutSeconds) {
- this.managedLedgerMetadataOperationsTimeoutSeconds =
managedLedgerMetadataOperationsTimeoutSeconds;
- }
-
- public boolean isLoadBalancerEnabled() {
- return loadBalancerEnabled;
- }
-
- public void setLoadBalancerEnabled(boolean loadBalancerEnabled) {
- this.loadBalancerEnabled = loadBalancerEnabled;
- }
-
- public void setLoadBalancerPlacementStrategy(String placementStrategy) {
- this.loadBalancerPlacementStrategy = placementStrategy;
- }
-
- public String getLoadBalancerPlacementStrategy() {
- return this.loadBalancerPlacementStrategy;
- }
-
- public int getLoadBalancerReportUpdateThresholdPercentage() {
- return loadBalancerReportUpdateThresholdPercentage;
- }
-
- public void setLoadBalancerReportUpdateThresholdPercentage(int
loadBalancerReportUpdateThresholdPercentage) {
- this.loadBalancerReportUpdateThresholdPercentage =
loadBalancerReportUpdateThresholdPercentage;
- }
-
- public int getLoadBalancerReportUpdateMaxIntervalMinutes() {
- return loadBalancerReportUpdateMaxIntervalMinutes;
- }
-
- public void setLoadBalancerReportUpdateMaxIntervalMinutes(int
loadBalancerReportUpdateMaxIntervalMinutes) {
- this.loadBalancerReportUpdateMaxIntervalMinutes =
loadBalancerReportUpdateMaxIntervalMinutes;
- }
-
- public int getLoadBalancerHostUsageCheckIntervalMinutes() {
- return loadBalancerHostUsageCheckIntervalMinutes;
- }
-
- public void setLoadBalancerHostUsageCheckIntervalMinutes(int
loadBalancerHostUsageCheckIntervalMinutes) {
- this.loadBalancerHostUsageCheckIntervalMinutes =
loadBalancerHostUsageCheckIntervalMinutes;
- }
-
- public boolean isLoadBalancerSheddingEnabled() {
- return loadBalancerSheddingEnabled;
- }
-
- public void setLoadBalancerSheddingEnabled(boolean
loadBalancerSheddingEnabled) {
- this.loadBalancerSheddingEnabled = loadBalancerSheddingEnabled;
- }
-
- public int getLoadBalancerSheddingIntervalMinutes() {
- return loadBalancerSheddingIntervalMinutes;
- }
-
- public void setLoadBalancerSheddingIntervalMinutes(int
loadBalancerSheddingIntervalMinutes) {
- this.loadBalancerSheddingIntervalMinutes =
loadBalancerSheddingIntervalMinutes;
- }
-
- public long getLoadBalancerSheddingGracePeriodMinutes() {
- return loadBalancerSheddingGracePeriodMinutes;
- }
-
- public void setLoadBalancerSheddingGracePeriodMinutes(long
loadBalancerSheddingGracePeriodMinutes) {
- this.loadBalancerSheddingGracePeriodMinutes =
loadBalancerSheddingGracePeriodMinutes;
- }
-
- public int getLoadBalancerResourceQuotaUpdateIntervalMinutes() {
- return this.loadBalancerResourceQuotaUpdateIntervalMinutes;
- }
-
- public void setLoadBalancerResourceQuotaUpdateIntervalMinutes(int
interval) {
- this.loadBalancerResourceQuotaUpdateIntervalMinutes = interval;
- }
-
- public int getLoadBalancerBrokerUnderloadedThresholdPercentage() {
- return loadBalancerBrokerUnderloadedThresholdPercentage;
- }
-
- public void setLoadBalancerBrokerUnderloadedThresholdPercentage(
- int loadBalancerBrokerUnderloadedThresholdPercentage) {
- this.loadBalancerBrokerUnderloadedThresholdPercentage =
loadBalancerBrokerUnderloadedThresholdPercentage;
- }
-
- public int getLoadBalancerBrokerOverloadedThresholdPercentage() {
- return loadBalancerBrokerOverloadedThresholdPercentage;
- }
-
- public int getLoadBalancerBrokerMaxTopics() {
- return loadBalancerBrokerMaxTopics;
- }
-
- public void setLoadBalancerBrokerMaxTopics(int
loadBalancerBrokerMaxTopics) {
- this.loadBalancerBrokerMaxTopics = loadBalancerBrokerMaxTopics;
- }
-
- public void setLoadBalancerNamespaceBundleMaxTopics(int topics) {
- this.loadBalancerNamespaceBundleMaxTopics = topics;
- }
-
- public int getLoadBalancerNamespaceBundleMaxTopics() {
- return this.loadBalancerNamespaceBundleMaxTopics;
- }
-
- public void setLoadBalancerNamespaceBundleMaxSessions(int sessions) {
- this.loadBalancerNamespaceBundleMaxSessions = sessions;
- }
-
- public int getLoadBalancerNamespaceBundleMaxSessions() {
- return this.loadBalancerNamespaceBundleMaxSessions;
- }
-
- public void setLoadBalancerNamespaceBundleMaxMsgRate(int msgRate) {
- this.loadBalancerNamespaceBundleMaxMsgRate = msgRate;
- }
-
- public int getLoadBalancerNamespaceBundleMaxMsgRate() {
- return this.loadBalancerNamespaceBundleMaxMsgRate;
- }
-
- public void setLoadBalancerNamespaceBundleMaxBandwidthMbytes(int
bandwidth) {
- this.loadBalancerNamespaceBundleMaxBandwidthMbytes = bandwidth;
- }
-
- public int getLoadBalancerNamespaceBundleMaxBandwidthMbytes() {
- return this.loadBalancerNamespaceBundleMaxBandwidthMbytes;
- }
-
- public void setLoadBalancerBrokerOverloadedThresholdPercentage(
- int loadBalancerBrokerOverloadedThresholdPercentage) {
- this.loadBalancerBrokerOverloadedThresholdPercentage =
loadBalancerBrokerOverloadedThresholdPercentage;
- }
-
- public int getLoadBalancerBrokerComfortLoadLevelPercentage() {
- return this.loadBalancerBrokerComfortLoadLevelPercentage;
- }
-
- public void setLoadBalancerBrokerComfortLoadLevelPercentage(int
percentage) {
- this.loadBalancerBrokerComfortLoadLevelPercentage = percentage;
- }
-
- public boolean isLoadBalancerAutoBundleSplitEnabled() {
- return this.loadBalancerAutoBundleSplitEnabled;
- }
-
- public void setLoadBalancerAutoBundleSplitEnabled(boolean enabled) {
- this.loadBalancerAutoBundleSplitEnabled = enabled;
- }
-
- public boolean isLoadBalancerAutoUnloadSplitBundlesEnabled() {
- return loadBalancerAutoUnloadSplitBundlesEnabled;
- }
-
- public void setLoadBalancerAutoUnloadSplitBundlesEnabled(boolean
loadBalancerAutoUnloadSplitBundlesEnabled) {
- this.loadBalancerAutoUnloadSplitBundlesEnabled =
loadBalancerAutoUnloadSplitBundlesEnabled;
- }
-
- public void setLoadBalancerNamespaceMaximumBundles(int bundles) {
- this.loadBalancerNamespaceMaximumBundles = bundles;
- }
-
- public int getLoadBalancerNamespaceMaximumBundles() {
- return this.loadBalancerNamespaceMaximumBundles;
- }
-
- public Optional<Double> getLoadBalancerOverrideBrokerNicSpeedGbps() {
- return Optional.ofNullable(loadBalancerOverrideBrokerNicSpeedGbps);
- }
-
- public void setLoadBalancerOverrideBrokerNicSpeedGbps(double
loadBalancerOverrideBrokerNicSpeedGbps) {
- this.loadBalancerOverrideBrokerNicSpeedGbps =
loadBalancerOverrideBrokerNicSpeedGbps;
- }
-
- public boolean isReplicationMetricsEnabled() {
- return replicationMetricsEnabled;
- }
-
- public void setReplicationMetricsEnabled(boolean
replicationMetricsEnabled) {
- this.replicationMetricsEnabled = replicationMetricsEnabled;
- }
-
- public int getReplicationConnectionsPerBroker() {
- return replicationConnectionsPerBroker;
- }
-
- public void setReplicationConnectionsPerBroker(int
replicationConnectionsPerBroker) {
- this.replicationConnectionsPerBroker = replicationConnectionsPerBroker;
- }
-
- public int getReplicationProducerQueueSize() {
- return replicationProducerQueueSize;
- }
-
- public void setReplicationProducerQueueSize(int
replicationProducerQueueSize) {
- this.replicationProducerQueueSize = replicationProducerQueueSize;
- }
-
- @Deprecated
- public boolean isReplicationTlsEnabled() {
- return replicationTlsEnabled;
- }
-
- @Deprecated
- public void setReplicationTlsEnabled(boolean replicationTlsEnabled) {
- this.replicationTlsEnabled = replicationTlsEnabled;
- }
-
- public boolean isBrokerClientTlsEnabled() {
- return brokerClientTlsEnabled || replicationTlsEnabled;
- }
-
- public void setBrokerClientTlsEnabled(boolean brokerClientTlsEnabled) {
- this.brokerClientTlsEnabled = brokerClientTlsEnabled;
- }
-
- public List<String> getBootstrapNamespaces() {
- return bootstrapNamespaces;
- }
-
- public Object getProperty(String key) {
- return properties.get(key);
- }
-
- @Override
- public Properties getProperties() {
- return properties;
- }
-
- @Override
- public void setProperties(Properties properties) {
- this.properties = properties;
- }
-
- public int getDefaultRetentionTimeInMinutes() {
- return defaultRetentionTimeInMinutes;
- }
-
- public void setDefaultRetentionTimeInMinutes(int
defaultRetentionTimeInMinutes) {
- this.defaultRetentionTimeInMinutes = defaultRetentionTimeInMinutes;
- }
-
- public int getDefaultRetentionSizeInMB() {
- return defaultRetentionSizeInMB;
- }
-
- public void setDefaultRetentionSizeInMB(int defaultRetentionSizeInMB) {
- this.defaultRetentionSizeInMB = defaultRetentionSizeInMB;
- }
-
- public int getBookkeeperHealthCheckIntervalSec() {
- return (int) bookkeeperClientHealthCheckIntervalSeconds;
- }
-
- public void setBootstrapNamespaces(List<String> bootstrapNamespaces) {
- this.bootstrapNamespaces = bootstrapNamespaces;
- }
-
- public void setBrokerServicePurgeInactiveFrequencyInSeconds(int
brokerServicePurgeInactiveFrequencyInSeconds) {
- this.brokerServicePurgeInactiveFrequencyInSeconds =
brokerServicePurgeInactiveFrequencyInSeconds;
- }
-
- public int getKeepAliveIntervalSeconds() {
- return keepAliveIntervalSeconds;
- }
-
- public void setKeepAliveIntervalSeconds(int keepAliveIntervalSeconds) {
- this.keepAliveIntervalSeconds = keepAliveIntervalSeconds;
- }
-
- public int getBrokerServicePurgeInactiveFrequencyInSeconds() {
- return brokerServicePurgeInactiveFrequencyInSeconds;
- }
-
- public long getZooKeeperSessionTimeoutMillis() {
- return zooKeeperSessionTimeoutMillis;
- }
-
- public void setZooKeeperSessionTimeoutMillis(long
zooKeeperSessionTimeoutMillis) {
- this.zooKeeperSessionTimeoutMillis = zooKeeperSessionTimeoutMillis;
- }
-
- public String getReplicatorPrefix() {
- return replicatorPrefix;
- }
-
- public void setReplicatorPrefix(String replicatorPrefix) {
- this.replicatorPrefix = replicatorPrefix;
- }
-
- public String getLoadManagerClassName() {
- return loadManagerClassName;
- }
-
- public void setLoadManagerClassName(String loadManagerClassName) {
- this.loadManagerClassName = loadManagerClassName;
- }
-
- public boolean isPreferLaterVersions() {
- return preferLaterVersions;
- }
-
- public void setPreferLaterVersions(boolean preferLaterVersions) {
- this.preferLaterVersions = preferLaterVersions;
- }
-
- public int getWebSocketNumIoThreads() { return webSocketNumIoThreads; }
-
- public void setWebSocketNumIoThreads(int webSocketNumIoThreads) {
this.webSocketNumIoThreads = webSocketNumIoThreads; }
-
- public int getWebSocketConnectionsPerBroker() { return
webSocketConnectionsPerBroker; }
-
- public void setWebSocketConnectionsPerBroker(int
webSocketConnectionsPerBroker) { this.webSocketConnectionsPerBroker =
webSocketConnectionsPerBroker; }
-
- public int getWebSocketSessionIdleTimeoutMillis() {
- return webSocketSessionIdleTimeoutMillis;
- }
-
- public void setWebSocketSessionIdleTimeoutMillis(int
webSocketSessionIdleTimeoutMillis) {
- this.webSocketSessionIdleTimeoutMillis =
webSocketSessionIdleTimeoutMillis;
- }
-
- public boolean exposeTopicLevelMetricsInPrometheus() {
- return exposeTopicLevelMetricsInPrometheus;
- }
-
- public boolean exposeConsumerLevelMetricsInPrometheus() {
- return exposeConsumerLevelMetricsInPrometheus;
- }
-
- public void setExposeTopicLevelMetricsInPrometheus(boolean
exposeTopicLevelMetricsInPrometheus) {
- this.exposeTopicLevelMetricsInPrometheus =
exposeTopicLevelMetricsInPrometheus;
- }
-
- public void setExposeConsumerLevelMetricsInPrometheus(boolean
exposeConsumerLevelMetricsInPrometheus) {
- this.exposeConsumerLevelMetricsInPrometheus =
exposeConsumerLevelMetricsInPrometheus;
- }
-
- public boolean isSchemaValidationEnforced() {
- return isSchemaValidationEnforced;
- }
-
- public void setSchemaValidationEnforced(boolean enforced) {
- this.isSchemaValidationEnforced = enforced;
- }
-
- public String getSchemaRegistryStorageClassName() {
- return schemaRegistryStorageClassName;
- }
-
- public void setSchemaRegistryStorageClassName(String className) {
- schemaRegistryStorageClassName = className;
- }
-
- public Set<String> getSchemaRegistryCompatibilityCheckers() {
- return schemaRegistryCompatibilityCheckers;
- }
-
- public void setSchemaRegistryCompatibilityCheckers(Set<String>
schemaRegistryCompatibilityCheckers) {
- this.schemaRegistryCompatibilityCheckers =
schemaRegistryCompatibilityCheckers;
- }
-
- public boolean authenticateOriginalAuthData() {
- return authenticateOriginalAuthData;
- }
-
- public void setAuthenticateOriginalAuthData(boolean
authenticateOriginalAuthData) {
- this.authenticateOriginalAuthData = authenticateOriginalAuthData;
- }
-
- public Set<String> getTlsProtocols() {
- return tlsProtocols;
- }
-
- public void setTlsProtocols(Set<String> tlsProtocols) {
- this.tlsProtocols = tlsProtocols;
- }
-
- public Set<String> getTlsCiphers() {
- return tlsCiphers;
- }
-
- public void setTlsCiphers(Set<String> tlsCiphers) {
- this.tlsCiphers = tlsCiphers;
- }
-
- public boolean getTlsRequireTrustedClientCertOnConnect() {
- return tlsRequireTrustedClientCertOnConnect;
- }
-
- public void setTlsRequireTrustedClientCertOnConnect(boolean
tlsRequireTrustedClientCertOnConnect) {
- this.tlsRequireTrustedClientCertOnConnect =
tlsRequireTrustedClientCertOnConnect;
- }
- /**** --- Function ---- ****/
-
- public void setFunctionsWorkerEnabled(boolean enabled) {
- this.functionsWorkerEnabled = enabled;
- }
-
- public boolean isFunctionsWorkerEnabled() {
- return functionsWorkerEnabled;
- }
-
-
- /**** --- Broker Web Stats ---- ****/
-
- public void setExposePublisherStats(boolean expose) {
- this.exposePublisherStats = expose;
- }
-
- public boolean exposePublisherStats() {
- return exposePublisherStats;
- }
-
- public boolean isRunningStandalone() {
- return isRunningStandalone;
- }
-
- public int getStatsUpdateFrequencyInSecs() {
- return statsUpdateFrequencyInSecs;
- }
-
- public void setStatsUpdateFrequencyInSecs(int statsUpdateFrequencyInSecs) {
- this.statsUpdateFrequencyInSecs = statsUpdateFrequencyInSecs;
- }
-
- public int getStatsUpdateInitialDelayInSecs() {
- return statsUpdateInitailDelayInSecs;
- }
-
- public void setStatsUpdateInitailDelayInSecs(int
statsUpdateInitailDelayInSecs) {
- this.statsUpdateInitailDelayInSecs = statsUpdateInitailDelayInSecs;
- }
-
- public void setRunningStandalone(boolean isRunningStandalone) {
- this.isRunningStandalone = isRunningStandalone;
- }
-
- /**** --- Ledger Offload ---- ****/
- public void setManagedLedgerOffloadDriver(String driver) {
- this.managedLedgerOffloadDriver = driver;
- }
-
- public String getManagedLedgerOffloadDriver() {
- return this.managedLedgerOffloadDriver;
- }
-
- public void setManagedLedgerOffloadMaxThreads(int maxThreads) {
- this.managedLedgerOffloadMaxThreads = maxThreads;
- }
-
- public int getManagedLedgerOffloadMaxThreads() {
- return this.managedLedgerOffloadMaxThreads;
- }
-
- public String getOffloadersDirectory() {
- return offloadersDirectory;
- }
-
- public void setOffloadersDirectory(String dir) {
- this.offloadersDirectory = dir;
- }
-
- public void setBrokerServiceCompactionMonitorIntervalInSeconds(int
interval) {
- this.brokerServiceCompactionMonitorIntervalInSeconds = interval;
- }
-
- public int getBrokerServiceCompactionMonitorIntervalInSeconds() {
- return this.brokerServiceCompactionMonitorIntervalInSeconds;
- }
-
- public BacklogQuota.RetentionPolicy
getBacklogQuotaDefaultRetentionPolicy() {
- return backlogQuotaDefaultRetentionPolicy;
- }
-
- public void
setBacklogQuotaDefaultRetentionPolicy(BacklogQuota.RetentionPolicy
backlogQuotaDefaultRetentionPolicy) {
- this.backlogQuotaDefaultRetentionPolicy =
backlogQuotaDefaultRetentionPolicy;
- }
-
- public int getSubscribeThrottlingRatePerConsumer() {
- return subscribeThrottlingRatePerConsumer;
- }
-
- public void setSubscribeThrottlingRatePerConsumer(int
subscribeThrottlingRatePerConsumer) {
- this.subscribeThrottlingRatePerConsumer =
subscribeThrottlingRatePerConsumer;
- }
-
- public int getSubscribeRatePeriodPerConsumerInSecond() {
- return subscribeRatePeriodPerConsumerInSecond;
- }
-
- public void setSubscribeRatePeriodPerConsumerInSecond(int
subscribeRatePeriodPerConsumerInSecond) {
- this.subscribeRatePeriodPerConsumerInSecond =
subscribeRatePeriodPerConsumerInSecond;
- }
}
diff --git
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
index fcd89b49b9..4af6a0a232 100644
---
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
+++
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
@@ -292,7 +292,7 @@ private boolean checkCluster(TopicName topicName) {
}
// Using wildcard
- if (conf.getAuthorizationAllowWildcardsMatching()) {
+ if (conf.isAuthorizationAllowWildcardsMatching()) {
if (checkWildcardPermission(role, action,
namespaceRoles)) {
// The role has namespace level permission by
wildcard match
permissionFuture.complete(true);
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
index 195f4d57f8..37c4906efa 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -381,7 +381,7 @@ public Boolean get() {
this.webService.addRestResources("/lookup",
"org.apache.pulsar.broker.lookup", true, attributeMap);
this.webService.addServlet("/metrics",
- new ServletHolder(new PrometheusMetricsServlet(this,
config.exposeTopicLevelMetricsInPrometheus(),
config.exposeConsumerLevelMetricsInPrometheus())),
+ new ServletHolder(new PrometheusMetricsServlet(this,
config.isExposeTopicLevelMetricsInPrometheus(),
config.isExposeConsumerLevelMetricsInPrometheus())),
false, attributeMap);
if (config.isWebSocketServiceEnabled()) {
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java
index a3fb772f56..f245af3548 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java
@@ -55,7 +55,7 @@ protected void initChannel(SocketChannel ch) throws Exception
{
serviceConfig.isTlsAllowInsecureConnection(),
serviceConfig.getTlsTrustCertsFilePath(),
serviceConfig.getTlsCertificateFilePath(),
serviceConfig.getTlsKeyFilePath(),
serviceConfig.getTlsCiphers(),
serviceConfig.getTlsProtocols(),
- serviceConfig.getTlsRequireTrustedClientCertOnConnect());
+ serviceConfig.isTlsRequireTrustedClientCertOnConnect());
ch.pipeline().addLast(TLS_HANDLER, sslCtx.newHandler(ch.alloc()));
ch.pipeline().addLast("ByteBufPairEncoder",
ByteBufPair.COPYING_ENCODER);
} else {
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarStats.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarStats.java
index 9fd02ae2f9..678abf3bd5 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarStats.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarStats.java
@@ -76,7 +76,7 @@ public PulsarStats(PulsarService pulsar) {
pulsar.getAdvertisedAddress());
this.tempNonPersistentTopics = Lists.newArrayList();
- this.exposePublisherStats =
pulsar.getConfiguration().exposePublisherStats();
+ this.exposePublisherStats =
pulsar.getConfiguration().isExposePublisherStats();
}
@Override
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
index 181c74cfbd..ab5797d986 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
@@ -53,7 +53,6 @@
import org.apache.pulsar.broker.PulsarService;
import org.apache.pulsar.broker.authentication.AuthenticationDataCommand;
import org.apache.pulsar.broker.authentication.AuthenticationDataSource;
-import org.apache.pulsar.broker.namespace.NamespaceService;
import
org.apache.pulsar.broker.service.BrokerServiceException.ConsumerBusyException;
import
org.apache.pulsar.broker.service.BrokerServiceException.ServerMetadataException;
import
org.apache.pulsar.broker.service.BrokerServiceException.ServiceUnitNotReadyException;
@@ -148,7 +147,7 @@ public ServerCnx(PulsarService pulsar) {
this.MaxNonPersistentPendingMessages =
service.pulsar().getConfiguration()
.getMaxConcurrentNonPersistentMessagePerConnection();
this.proxyRoles = service.pulsar().getConfiguration().getProxyRoles();
- this.authenticateOriginalAuthData =
service.pulsar().getConfiguration().authenticateOriginalAuthData();
+ this.authenticateOriginalAuthData =
service.pulsar().getConfiguration().isAuthenticateOriginalAuthData();
this.schemaValidationEnforced =
pulsar.getConfiguration().isSchemaValidationEnforced();
}
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java
index 04df62f59c..02243b9558 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java
@@ -93,7 +93,7 @@ public WebService(PulsarService pulsar) throws
PulsarServerException {
pulsar.getConfiguration().getTlsTrustCertsFilePath(),
pulsar.getConfiguration().getTlsCertificateFilePath(),
pulsar.getConfiguration().getTlsKeyFilePath(),
-
pulsar.getConfiguration().getTlsRequireTrustedClientCertOnConnect());
+
pulsar.getConfiguration().isTlsRequireTrustedClientCertOnConnect());
ServerConnector tlsConnector = new
PulsarServerConnector(server, 1, 1, sslCtxFactory);
tlsConnector.setPort(pulsar.getConfiguration().getWebServicePortTls());
tlsConnector.setHost(pulsar.getBindAddress());
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
