diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-02-18 07:59:32 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-02-18 07:59:32 -0800 |
| commit | abd50dc323ad215920ec3b6dfd07d729c64e2b7a (patch) | |
| tree | ab6ca8de6456a9e2fb2fe242f982b4f764bdb543 /kafka/consumer | |
| parent | bcdefd698d03af65413d9feff522b22dd3b7eebb (diff) | |
| parent | 9bf304ab438b30cc554e464f1ff275dd61a6444e (diff) | |
| download | kafka-python-abd50dc323ad215920ec3b6dfd07d729c64e2b7a.tar.gz | |
Merge pull request #557 from dpkp/socket_buffer_size_optional
Dont override system rcvbuf or sndbuf unless user configures explicitly
Diffstat (limited to 'kafka/consumer')
| -rw-r--r-- | kafka/consumer/group.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index d4ddc2d..cf77df3 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -113,9 +113,11 @@ class KafkaConsumer(six.Iterator): session_timeout_ms (int): The timeout used to detect failures when using Kafka's group managementment facilities. Default: 30000 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). The 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). The java client defaults to 32768. consumer_timeout_ms (int): number of millisecond to throw a timeout exception to the consumer if no message is available for consumption. Default: -1 (dont throw exception) @@ -151,8 +153,8 @@ class KafkaConsumer(six.Iterator): 'partition_assignment_strategy': (RangePartitionAssignor, RoundRobinPartitionAssignor), 'heartbeat_interval_ms': 3000, 'session_timeout_ms': 30000, - 'send_buffer_bytes': 128 * 1024, - 'receive_buffer_bytes': 32 * 1024, + 'send_buffer_bytes': None, + 'receive_buffer_bytes': None, 'consumer_timeout_ms': -1, 'api_version': 'auto', 'connections_max_idle_ms': 9 * 60 * 1000, # not implemented yet |