style: use triple quotes for docstrings

Author: Vetoshkin Nikita

kafka/client.py

@@ -37,7 +37,9 @@ def __init__(self, host, port, bufsize=4096, client_id=CLIENT_ID):
     ##################
 
     def _get_conn_for_broker(self, broker):
-        "Get or create a connection to a broker"
+        """
+        Get or create a connection to a broker
+        """
         if (broker.host, broker.port) not in self.conns:
             self.conns[(broker.host, broker.port)] = \
                 KafkaConnection(broker.host, broker.port, self.bufsize)
@@ -97,7 +99,9 @@ def _load_metadata_for_topics(self, *topics):
                     self.topic_partitions[topic].append(partition)
 
     def _next_id(self):
-        "Generate a new correlation id"
+        """
+        Generate a new correlation id
+        """
         return KafkaClient.ID_GEN.next()
 
     def _send_broker_unaware_request(self, requestId, request):

kafka/conn.py

@@ -80,13 +80,17 @@ def send(self, requestId, payload):
             raise RuntimeError("Kafka went away")
 
     def recv(self, requestId):
-        "Get a response from Kafka"
+        """
+        Get a response from Kafka
+        """
         log.debug("Reading response %d from Kafka" % requestId)
         self.data = self._consume_response()
         return self.data
 
     def close(self):
-        "Close this connection"
+        """
+        Close this connection
+        """
         self._sock.close()
 
     def reinit(self):