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/01/26 01:19:53 UTC
[incubator-pulsar] branch master updated: Increase client setting
concurrentLookupRequest default to 50K (#1116)
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/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new d66e427 Increase client setting concurrentLookupRequest default to 50K (#1116)
d66e427 is described below
commit d66e427ed9a58d6ab7017b230c6221be15314933
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Thu Jan 25 17:19:50 2018 -0800
Increase client setting concurrentLookupRequest default to 50K (#1116)
---
pulsar-client-cpp/include/pulsar/ClientConfiguration.h | 2 +-
pulsar-client-cpp/lib/ClientConfigurationImpl.h | 2 +-
pulsar-client-cpp/python/pulsar.py | 2 +-
.../apache/pulsar/client/api/ClientConfiguration.java | 16 ++++++++--------
4 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/pulsar-client-cpp/include/pulsar/ClientConfiguration.h b/pulsar-client-cpp/include/pulsar/ClientConfiguration.h
index 08cfdf0..137d528 100644
--- a/pulsar-client-cpp/include/pulsar/ClientConfiguration.h
+++ b/pulsar-client-cpp/include/pulsar/ClientConfiguration.h
@@ -88,7 +88,7 @@ class ClientConfiguration {
/**
* Number of concurrent lookup-requests allowed on each broker-connection to prevent overload on broker.
- * <i>(default: 5000)</i> It should be configured with higher value only in case of it requires to
+ * <i>(default: 50000)</i> It should be configured with higher value only in case of it requires to
* produce/subscribe on
* thousands of topic using created {@link PulsarClient}
*
diff --git a/pulsar-client-cpp/lib/ClientConfigurationImpl.h b/pulsar-client-cpp/lib/ClientConfigurationImpl.h
index 14a5fda..4ea77cf 100644
--- a/pulsar-client-cpp/lib/ClientConfigurationImpl.h
+++ b/pulsar-client-cpp/lib/ClientConfigurationImpl.h
@@ -39,7 +39,7 @@ struct ClientConfigurationImpl {
ioThreads(1),
operationTimeoutSeconds(30),
messageListenerThreads(1),
- concurrentLookupRequest(5000),
+ concurrentLookupRequest(50000),
logConfFilePath(),
useTls(false),
tlsAllowInsecureConnection(true),
diff --git a/pulsar-client-cpp/python/pulsar.py b/pulsar-client-cpp/python/pulsar.py
index 9cdb90d..8c1ff45 100644
--- a/pulsar-client-cpp/python/pulsar.py
+++ b/pulsar-client-cpp/python/pulsar.py
@@ -202,7 +202,7 @@ class Client:
operation_timeout_seconds=30,
io_threads=1,
message_listener_threads=1,
- concurrent_lookup_requests=5000,
+ concurrent_lookup_requests=50000,
log_conf_file_path=None,
use_tls=False,
tls_trust_certs_file_path=None,
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/api/ClientConfiguration.java b/pulsar-client/src/main/java/org/apache/pulsar/client/api/ClientConfiguration.java
index 9c3e662..dd62728 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/api/ClientConfiguration.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/api/ClientConfiguration.java
@@ -51,7 +51,7 @@ public class ClientConfiguration implements Serializable {
private boolean useTls = false;
private String tlsTrustCertsFilePath = "";
private boolean tlsAllowInsecureConnection = false;
- private int concurrentLookupRequest = 5000;
+ private int concurrentLookupRequest = 50000;
private int maxNumberOfRejectedRequestPerConnection = 50;
/**
@@ -296,7 +296,7 @@ public class ClientConfiguration implements Serializable {
/**
* Stats will be activated with positive statsIntervalSeconds
- *
+ *
* @return the interval between each stat info <i>(default: 60 seconds)</i>
*/
public long getStatsIntervalSeconds() {
@@ -306,7 +306,7 @@ public class ClientConfiguration implements Serializable {
/**
* Set the interval between each stat info <i>(default: 60 seconds)</i> Stats will be activated with positive
* statsIntervalSeconds It should be set to at least 1 second
- *
+ *
* @param statsIntervalSeconds
* the interval between each stat info
* @param unit
@@ -318,7 +318,7 @@ public class ClientConfiguration implements Serializable {
/**
* Get configured total allowed concurrent lookup-request.
- *
+ *
* @return
*/
public int getConcurrentLookupRequest() {
@@ -327,9 +327,9 @@ public class ClientConfiguration implements Serializable {
/**
* Number of concurrent lookup-requests allowed on each broker-connection to prevent overload on broker.
- * <i>(default: 5000)</i> It should be configured with higher value only in case of it requires to produce/subscribe on
+ * <i>(default: 50000)</i> It should be configured with higher value only in case of it requires to produce/subscribe on
* thousands of topic using created {@link PulsarClient}
- *
+ *
* @param concurrentLookupRequest
*/
public void setConcurrentLookupRequest(int concurrentLookupRequest) {
@@ -338,7 +338,7 @@ public class ClientConfiguration implements Serializable {
/**
* Get configured max number of reject-request in a time-frame (30 seconds) after which connection will be closed
- *
+ *
* @return
*/
public int getMaxNumberOfRejectedRequestPerConnection() {
@@ -349,7 +349,7 @@ public class ClientConfiguration implements Serializable {
* Set max number of broker-rejected requests in a certain time-frame (30 seconds) after which current connection
* will be closed and client creates a new connection that give chance to connect a different broker <i>(default:
* 50)</i>
- *
+ *
* @param maxNumberOfRejectedRequestPerConnection
*/
public void setMaxNumberOfRejectedRequestPerConnection(int maxNumberOfRejectedRequestPerConnection) {
--
To stop receiving notification emails like this one, please contact
mmerli@apache.org.