From a69320b8e3199fa9d7cfa3947a242e699a045c3b Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Wed, 10 Jan 2018 17:25:33 -0800
Subject: Read all available socket bytes (#1332)

* Recv all available network bytes before parsing
* Add experimental support for configuring socket chunking parameters
---
 kafka/client_async.py | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'kafka/client_async.py')

diff --git a/kafka/client_async.py b/kafka/client_async.py
index 0058cf3..29cb8c0 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -154,6 +154,8 @@ class KafkaClient(object):
         'receive_buffer_bytes': None,
         'send_buffer_bytes': None,
         'socket_options': [(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)],
+        'sock_chunk_bytes': 4096,  # undocumented experimental option
+        'sock_chunk_buffer_count': 1000,  # undocumented experimental option
         'retry_backoff_ms': 100,
         'metadata_max_age_ms': 300000,
         'security_protocol': 'PLAINTEXT',
-- 
cgit v1.2.1