diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-06-18 16:43:20 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-06-18 23:21:22 -0700 |
| commit | 8818987162696802ef0a7d91237a6d4bb583d437 (patch) | |
| tree | 5ec93e5a3cefd1f12822b2cd2a8f9591e7b10f95 | |
| parent | 0b5a49e58d16336c1a632a4f5e42bc4fbbb3d118 (diff) | |
| download | kafka-python-8818987162696802ef0a7d91237a6d4bb583d437.tar.gz | |
Mute all connection logging during conn.check_version
| -rw-r--r-- | kafka/conn.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index c5d3be1..24a2b98 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -561,9 +561,9 @@ class BrokerConnection(object): class ConnFilter(Filter): def filter(self, record): - if record.funcName in ('recv', 'send'): - return False - return True + if record.funcName == 'check_version': + return True + return False log_filter = ConnFilter() log.addFilter(log_filter) |