summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-02-17 22:21:36 -0800
committerDana Powers <dana.powers@gmail.com>2016-02-17 22:21:36 -0800
commit9bf304ab438b30cc554e464f1ff275dd61a6444e (patch)
treed9a275f0040f6eb14d15042019065d9b4ea10eca /kafka/conn.py
parentd5c05c811e453c507ac6f7f85bceffc5a7ba1661 (diff)
downloadkafka-python-socket_buffer_size_optional.tar.gz
Dont override system rcvbuf or sndbuf unless user configures explicitlysocket_buffer_size_optional
Diffstat (limited to 'kafka/conn.py')
-rw-r--r--kafka/conn.py14
1 files changed, 8 insertions, 6 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index 14c3b50..35d8d13 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -47,8 +47,8 @@ class BrokerConnection(object):
'request_timeout_ms': 40000,
'reconnect_backoff_ms': 50,
'max_in_flight_requests_per_connection': 5,
- 'receive_buffer_bytes': 32768,
- 'send_buffer_bytes': 131072,
+ 'receive_buffer_bytes': None,
+ 'send_buffer_bytes': None,
'api_version': (0, 8, 2), # default to most restrictive
}
@@ -77,10 +77,12 @@ class BrokerConnection(object):
if self.state is ConnectionStates.DISCONNECTED:
self.close()
self._sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
- self._sock.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF,
- self.config['receive_buffer_bytes'])
- self._sock.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF,
- self.config['send_buffer_bytes'])
+ if self.config['receive_buffer_bytes'] is not None:
+ self._sock.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF,
+ self.config['receive_buffer_bytes'])
+ if self.config['send_buffer_bytes'] is not None:
+ self._sock.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF,
+ self.config['send_buffer_bytes'])
self._sock.setblocking(False)
try:
ret = self._sock.connect_ex((self.host, self.port))