From fd1801907f85ac7686b9452c08ae908c3a88cd51 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 20 Dec 2015 10:27:52 -0800 Subject: New async KafkaClient, based on java NetworkClient and ConsumerClient - Support async client bootstrap retries after exponential backoff - Attempt to finish_connect if still connecting in KafkaClient.ready(node_id) - Run full async loop while waiting for futures in KafkaClient.poll() - Add more fallbacks to KafkaClient.least_loaded_node; worst case, retry boostrap --- kafka/common.py | 8 ++++++++ 1 file changed, 8 insertions(+) (limited to 'kafka/common.py') diff --git a/kafka/common.py b/kafka/common.py index eb612d7..f79150b 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -97,6 +97,10 @@ class IllegalStateError(KafkaError): pass +class IllegalArgumentError(KafkaError): + pass + + class RetriableError(KafkaError): pass @@ -109,6 +113,10 @@ class CorrelationIdError(KafkaError): pass +class Cancelled(KafkaError): + pass + + class TooManyInFlightRequests(KafkaError): pass -- cgit v1.2.1