diff --git a/pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ClientConfiguration.java b/pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ClientConfiguration.java index 52a86e23f06be..6ccb442c70487 100644 --- a/pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ClientConfiguration.java +++ b/pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ClientConfiguration.java @@ -319,7 +319,7 @@ public void setConcurrentLookupRequest(int concurrentLookupRequest) { } /** - * Get configured max number of reject-request in a time-frame (30 seconds) after which connection will be closed. + * Get configured max number of reject-request in a time-frame (60 seconds) after which connection will be closed. * * @return */ @@ -328,7 +328,7 @@ public int getMaxNumberOfRejectedRequestPerConnection() { } /** - * Set max number of broker-rejected requests in a certain time-frame (30 seconds) after which current connection. + * Set max number of broker-rejected requests in a certain time-frame (60 seconds) after which current connection. * will be closed and client creates a new connection that give chance to connect a different broker (default: * 50) * diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java index 6d44f20b8eef4..17852bc545dc0 100644 --- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java +++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java @@ -489,7 +489,7 @@ ClientBuilder authentication(String authPluginClassName, Map aut ClientBuilder maxLookupRedirects(int maxLookupRedirects); /** - * Set max number of broker-rejected requests in a certain time-frame (30 seconds) after which current connection + * Set max number of broker-rejected requests in a certain time-frame (60 seconds) after which current connection * will be closed and client creates a new connection that give chance to connect a different broker (default: * 50). * diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java index e6f25f4acf187..653dded4de67b 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java @@ -195,7 +195,7 @@ public class ClientConfigurationData implements Serializable, Cloneable { @ApiModelProperty( name = "maxNumberOfRejectedRequestPerConnection", - value = "Maximum number of rejected requests of a broker in a certain time frame (30 seconds) " + value = "Maximum number of rejected requests of a broker in a certain time frame (60 seconds) " + "after the current connection is closed and the client " + "creating a new connection to connect to a different broker." ) diff --git a/site2/docs/client-libraries-java.md b/site2/docs/client-libraries-java.md index cbe3156b5456b..2135c165a45b3 100644 --- a/site2/docs/client-libraries-java.md +++ b/site2/docs/client-libraries-java.md @@ -127,7 +127,7 @@ If you create a client, you can use the `loadConf` configuration. The following `tlsHostnameVerificationEnable` |boolean | Whether to enable TLS hostname verification|false `concurrentLookupRequest`|int|The number of concurrent lookup requests allowed to send on each broker connection to prevent overload on broker|5000 `maxLookupRequest`|int|The maximum number of lookup requests allowed on each broker connection to prevent overload on broker | 50000 -`maxNumberOfRejectedRequestPerConnection`|int|The maximum number of rejected requests of a broker in a certain time frame (30 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker|50 +`maxNumberOfRejectedRequestPerConnection`|int|The maximum number of rejected requests of a broker in a certain time frame (60 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker|50 `keepAliveIntervalSeconds`|int|Seconds of keeping alive interval for each client broker connection|30 `connectionTimeoutMs`|int|Duration of waiting for a connection to a broker to be established

If the duration passes without a response from a broker, the connection attempt is dropped|10000 `requestTimeoutMs`|int|Maximum duration for completing a request |60000 diff --git a/site2/website/versioned_docs/version-2.10.x/client-libraries-java.md b/site2/website/versioned_docs/version-2.10.x/client-libraries-java.md index 2709dab581581..6761a10f31704 100644 --- a/site2/website/versioned_docs/version-2.10.x/client-libraries-java.md +++ b/site2/website/versioned_docs/version-2.10.x/client-libraries-java.md @@ -147,7 +147,7 @@ If you create a client, you can use the `loadConf` configuration. The following `tlsHostnameVerificationEnable` |boolean | Whether to enable TLS hostname verification|false `concurrentLookupRequest`|int|The number of concurrent lookup requests allowed to send on each broker connection to prevent overload on broker|5000 `maxLookupRequest`|int|The maximum number of lookup requests allowed on each broker connection to prevent overload on broker | 50000 -`maxNumberOfRejectedRequestPerConnection`|int|The maximum number of rejected requests of a broker in a certain time frame (30 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker|50 +`maxNumberOfRejectedRequestPerConnection`|int|The maximum number of rejected requests of a broker in a certain time frame (60 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker|50 `keepAliveIntervalSeconds`|int|Seconds of keeping alive interval for each client broker connection|30 `connectionTimeoutMs`|int|Duration of waiting for a connection to a broker to be established

If the duration passes without a response from a broker, the connection attempt is dropped|10000 `requestTimeoutMs`|int|Maximum duration for completing a request |60000 diff --git a/site2/website/versioned_docs/version-2.8.x/client-libraries-java.md b/site2/website/versioned_docs/version-2.8.x/client-libraries-java.md index 930b59ac19bb4..df8fad4678f13 100644 --- a/site2/website/versioned_docs/version-2.8.x/client-libraries-java.md +++ b/site2/website/versioned_docs/version-2.8.x/client-libraries-java.md @@ -134,7 +134,7 @@ boolean|`tlsAllowInsecureConnection`|Whether the Pulsar client accepts untrusted boolean | `tlsHostnameVerificationEnable` | Whether to enable TLS hostname verification|false int|`concurrentLookupRequest`|The number of concurrent lookup requests allowed to send on each broker connection to prevent overload on broker|5000 int|`maxLookupRequest`|The maximum number of lookup requests allowed on each broker connection to prevent overload on broker | 50000 -int|`maxNumberOfRejectedRequestPerConnection`|The maximum number of rejected requests of a broker in a certain time frame (30 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker|50 +int|`maxNumberOfRejectedRequestPerConnection`|The maximum number of rejected requests of a broker in a certain time frame (60 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker|50 int|`keepAliveIntervalSeconds`|Seconds of keeping alive interval for each client broker connection|30 int|`connectionTimeoutMs`|Duration of waiting for a connection to a broker to be established

If the duration passes without a response from a broker, the connection attempt is dropped|10000 int|`requestTimeoutMs`|Maximum duration for completing a request |60000 diff --git a/site2/website/versioned_docs/version-2.9.x/client-libraries-java.md b/site2/website/versioned_docs/version-2.9.x/client-libraries-java.md index 56fb54d633daf..a611617b6f584 100644 --- a/site2/website/versioned_docs/version-2.9.x/client-libraries-java.md +++ b/site2/website/versioned_docs/version-2.9.x/client-libraries-java.md @@ -134,7 +134,7 @@ If you create a client, you can use the `loadConf` configuration. The following `tlsHostnameVerificationEnable` |boolean | Whether to enable TLS hostname verification|false `concurrentLookupRequest`|int|The number of concurrent lookup requests allowed to send on each broker connection to prevent overload on broker|5000 `maxLookupRequest`|int|The maximum number of lookup requests allowed on each broker connection to prevent overload on broker | 50000 -`maxNumberOfRejectedRequestPerConnection`|int|The maximum number of rejected requests of a broker in a certain time frame (30 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker|50 +`maxNumberOfRejectedRequestPerConnection`|int|The maximum number of rejected requests of a broker in a certain time frame (60 seconds) after the current connection is closed and the client creates a new connection to connect to a different broker|50 `keepAliveIntervalSeconds`|int|Seconds of keeping alive interval for each client broker connection|30 `connectionTimeoutMs`|int|Duration of waiting for a connection to a broker to be established

If the duration passes without a response from a broker, the connection attempt is dropped|10000 `requestTimeoutMs`|int|Maximum duration for completing a request |60000