diff options
| -rw-r--r-- | kafka/conn.py | 7 |
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): """ |