You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2018/12/01 05:50:42 UTC
[pulsar] branch master updated: [conf] Clean up
ServiceConfiguration to use lombok getter and setter (#3101)
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 a62633b [conf] Clean up ServiceConfiguration to use lombok getter and setter (#3101)
a62633b is described below
commit a62633b218f58d1b9cdba8524258920edd403208
Author: Sijie Guo <gu...@gmail.com>
AuthorDate: Fri Nov 30 21:50:37 2018 -0800
[conf] Clean up ServiceConfiguration to use lombok getter and setter (#3101)
*Motivation*
Each time we add a new setting, we need to add one setter and one getter method.
This change is to remove those setters and getters, to use lombok @Setter and @Getter.
It will make life easier.
---
.../apache/pulsar/broker/ServiceConfiguration.java | 1292 +-------------------
.../authorization/PulsarAuthorizationProvider.java | 2 +-
.../org/apache/pulsar/broker/PulsarService.java | 2 +-
.../broker/service/PulsarChannelInitializer.java | 2 +-
.../apache/pulsar/broker/service/PulsarStats.java | 2 +-
.../apache/pulsar/broker/service/ServerCnx.java | 3 +-
.../org/apache/pulsar/broker/web/WebService.java | 2 +-
7 files changed, 25 insertions(+), 1280 deletions(-)
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 9eba00e..34882bd 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 @@ public class ServiceConfiguration implements PulsarConfiguration {
// 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 @@ public class ServiceConfiguration implements PulsarConfiguration {
// 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 class ServiceConfiguration implements PulsarConfiguration {
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 fcd89b4..4af6a0a 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 @@ public class PulsarAuthorizationProvider implements AuthorizationProvider {
}
// 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 195f4d5..37c4906 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 class PulsarService implements AutoCloseable {
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 a3fb772..f245af3 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 @@ public class PulsarChannelInitializer extends ChannelInitializer<SocketChannel>
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 9fd02ae..678abf3 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 class PulsarStats implements Closeable {
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 181c74c..ab5797d 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.PulsarServerException;
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 class ServerCnx extends PulsarHandler {
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 04df62f..02243b9 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 class WebService implements AutoCloseable {
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());