Fix race condition in protocol.send_bytes (dpkp#1752)

isamaru · dpkp · commit ee4a53e9e5ae · 2019-03-21T07:39:08.000-07:00
diff --git a/kafka/conn.py b/kafka/conn.py
@@ -790,7 +790,8 @@ def send_pending_requests(self):
         if self.state not in (ConnectionStates.AUTHENTICATING,
                               ConnectionStates.CONNECTED):
             return Errors.NodeNotReadyError(str(self))
-        data = self._protocol.send_bytes()
+        with self._lock:
+            data = self._protocol.send_bytes()
         try:
             # In the future we might manage an internal write buffer
             # and send bytes asynchronously. For now, just block
