diff options
| -rw-r--r-- | kafka/client_async.py | 2 | ||||
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 | ||||
| -rw-r--r-- | kafka/errors.py | 4 |
3 files changed, 4 insertions, 4 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 9439451..c081f07 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -147,7 +147,7 @@ class KafkaClient(object): if self.config['api_version'] is not None: assert self.config['api_version'] in self.API_VERSIONS, ( - 'api_version [{}] must be one of: {}'.format( + 'api_version [{0}] must be one of: {1}'.format( self.config['api_version'], str(self.API_VERSIONS))) self.cluster = ClusterMetadata(**self.config) diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index d615848..11cd7ef 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -400,7 +400,7 @@ class Fetcher(six.Iterator): inner_timestamp = msg.timestamp else: - raise ValueError('Unknown timestamp type: {}'.format(msg.timestamp_type)) + raise ValueError('Unknown timestamp type: {0}'.format(msg.timestamp_type)) else: inner_timestamp = msg.timestamp diff --git a/kafka/errors.py b/kafka/errors.py index 3de6ff2..a517ea7 100644 --- a/kafka/errors.py +++ b/kafka/errors.py @@ -10,7 +10,7 @@ class KafkaError(RuntimeError): def __str__(self): if not self.args: return self.__class__.__name__ - return '{}: {}'.format(self.__class__.__name__, + return '{0}: {1}'.format(self.__class__.__name__, super(KafkaError, self).__str__()) @@ -63,7 +63,7 @@ class BrokerResponseError(KafkaError): def __str__(self): """Add errno to standard KafkaError str""" - return '[Error {}] {}: {}'.format( + return '[Error {0}] {1}: {2}'.format( self.errno, self.__class__.__name__, super(KafkaError, self).__str__()) # pylint: disable=bad-super-call |