diff options
Diffstat (limited to 'kafka/conn.py')
| -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) |