[KAFKA-3496] Add reconnect attemps policies for client

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 0.10.0.0
• Component/s: clients
• Assignee: Unassigned
• Reporter: Florian Hussonnois
• Created: 02/Apr/16 15:55
• Updated: 25/Jul/24 01:07
• Resolved: 22/Dec/17 02:01

Description

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);

Issue Links

• links to: GitHub Pull Request #1179