diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-03-13 21:56:02 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2019-03-13 22:18:19 -0700 |
| commit | 703f06590be2daa7e4592b3d82df6d719a6829bb (patch) | |
| tree | 4412119ecbafae45333c6af1b5bc48045e9ea5ac | |
| parent | 5d7a5fc2a3795274a328343cb638397421dcfdfb (diff) | |
| download | kafka-python-703f06590be2daa7e4592b3d82df6d719a6829bb.tar.gz | |
Fix default protocol parser version
| -rw-r--r-- | kafka/conn.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 4781b9a..e857d0a 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -230,6 +230,9 @@ class BrokerConnection(object): self.node_id = self.config.pop('node_id') + if self.config['api_version'] is None: + self.config['api_version'] = self.DEFAULT_CONFIG['api_version'] + if self.config['receive_buffer_bytes'] is not None: self.config['socket_options'].append( (socket.SOL_SOCKET, socket.SO_RCVBUF, |