diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-02-17 22:21:36 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-02-17 22:21:36 -0800 |
| commit | 9bf304ab438b30cc554e464f1ff275dd61a6444e (patch) | |
| tree | d9a275f0040f6eb14d15042019065d9b4ea10eca /kafka/client_async.py | |
| parent | d5c05c811e453c507ac6f7f85bceffc5a7ba1661 (diff) | |
| download | kafka-python-9bf304ab438b30cc554e464f1ff275dd61a6444e.tar.gz | |
Dont override system rcvbuf or sndbuf unless user configures explicitlysocket_buffer_size_optional
Diffstat (limited to 'kafka/client_async.py')
| -rw-r--r-- | kafka/client_async.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index f048be9..cb8152a 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -41,8 +41,8 @@ class KafkaClient(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, 'retry_backoff_ms': 100, 'metadata_max_age_ms': 300000, } @@ -71,9 +71,11 @@ class KafkaClient(object): to kafka brokers up to this number of maximum requests per broker connection. Default: 5. send_buffer_bytes (int): The size of the TCP send buffer - (SO_SNDBUF) to use when sending data. Default: 131072 + (SO_SNDBUF) to use when sending data. Default: None (relies on + system defaults). Java client defaults to 131072. receive_buffer_bytes (int): The size of the TCP receive buffer - (SO_RCVBUF) to use when reading data. Default: 32768 + (SO_RCVBUF) to use when reading data. Default: None (relies on + system defaults). Java client defaults to 32768. metadata_max_age_ms (int): The period of time in milliseconds after which we force a refresh of metadata even if we haven't seen any partition leadership changes to proactively discover any new |