| commit | 20aa14c13e47dc70380ac0209c8b4c01dcd5c179 | [log] [tgz] |
|---|---|---|
| author | Adnan Baruni <abaruni@users.noreply.github.com> | Mon Jan 29 13:47:24 2018 -0600 |
| committer | James Dubee <jwdubee@us.ibm.com> | Mon Jan 29 14:47:24 2018 -0500 |
| tree | d373cdffec720cd81b989d78641f9ee043a708e4 | |
| parent | b2ffb77194a7025a9d6ae0ae34db9d4309e4f4ab [diff] |
add logging for errors (#239)
diff --git a/provider/consumer.py b/provider/consumer.py index 2a0c65a..4728d27 100644 --- a/provider/consumer.py +++ b/provider/consumer.py
@@ -481,6 +481,7 @@ return key def __error_callback(self, error): + logging.warning(error) if not self.connected and error.code() == KafkaError._AUTHENTICATION: self.authErrors = self.authErrors + 1 if self.authErrors > self.maxAuthErrors: