reduce memory copies when consuming kafka responses

1 files changed, 2 insertions, 5 deletions

diff --git a/kafka/conn.py b/kafka/conn.py
index 14aebc6..1a3e260 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -38,12 +38,9 @@ class KafkaConnection(local):
 
     def _consume_response(self):
         """
-        Fully consumer the response iterator
+        Fully consume the response iterator
         """
-        data = ""
-        for chunk in self._consume_response_iter():
-            data += chunk
-        return data
+        return "".join(self._consume_response_iter())
 
     def _consume_response_iter(self):
         """