[jira] [Commented] (KAFKA-3496) Add reconnect attemps policies for client

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ 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 <fl...@gmail.com>
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)