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 <[email protected]>
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());
