[
https://issues.apache.org/jira/browse/KAFKA-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222925#comment-15222925
]
ASF GitHub Bot commented on KAFKA-3496:
---------------------------------------
GitHub user fhussonnois opened a pull request:
https://github.com/apache/kafka/pull/1179
KAFKA-3496 - add policies for client reconnect attempts
In addition, this PR fixes some log level as describe in this issue :
https://issues.apache.org/jira/browse/KAFKA-2998
This implementation is inspired from the cassandra client driver.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhussonnois/kafka client-reconnect-policy
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1179.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1179
----
commit 179f571fc75762f39d7769c895ba59f9eed86b95
Author: Florian Hussonnois <[email protected]>
Date: 2016-04-02T15:56:30Z
KAFKA-3496 - add policies for client reconnect attempts
----
> Add reconnect attemps policies for client
> -----------------------------------------
>
> Key: KAFKA-3496
> URL: https://issues.apache.org/jira/browse/KAFKA-3496
> Project: Kafka
> Issue Type: Improvement
> Components: clients
> Affects Versions: 0.10.0.0
> Reporter: Florian Hussonnois
>
> Currently the client reconnection attempts is only controlled by the property
> : reconnect.backoff.ms
> It would be nice to introduce a reconnect attempt policy. At first, two
> policies may be defined :
> - ConstantReconnectAttemptPolicy
> - ExponentialReconnectAttemptPolicy
> The policy could be then configure as follows :
> Properties config = new Properties();
> config.put(ConsumerConfig.RECONNECT_ATTEMPTS_POLICY_CLASS_CONFIG,
> "org.apache.kafka.clients.ExponentialReconnectAttemptPolicy");
> config.put(ConsumerConfig.RECONNECT_EXPONENTIAL_MAX_DELAY_MS_CONFIG, 5000);
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
