diff options
author | Mark Roberts <wizzat@gmail.com> | 2014-05-06 21:24:15 -0700 |
---|---|---|
committer | Mark Roberts <wizzat@gmail.com> | 2014-05-06 21:24:15 -0700 |
commit | efcf58b84214aeda6cf79319f182407cde7833a6 (patch) | |
tree | 94cbb3cc886432dc77bf09f7101982d871db0365 /kafka/consumer.py | |
parent | 99320fbd8c33f3b831557c507deeaf5e650ab813 (diff) | |
download | kafka-python-efcf58b84214aeda6cf79319f182407cde7833a6.tar.gz |
Attempt to fix travis build. Decrease complexity of service.py in favor of in memory logging. Address code review concerns
Diffstat (limited to 'kafka/consumer.py')
-rw-r--r-- | kafka/consumer.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index 085f5e8..ef8fbda 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -430,12 +430,12 @@ class SimpleConsumer(Consumer): # Put the message in our queue self.queue.put((partition, message)) self.fetch_offsets[partition] = message.offset + 1 - except ConsumerFetchSizeTooSmall as e: + except ConsumerFetchSizeTooSmall: if (self.max_buffer_size is not None and self.buffer_size == self.max_buffer_size): log.error("Max fetch size %d too small", self.max_buffer_size) - raise e + raise if self.max_buffer_size is None: self.buffer_size *= 2 else: |