PEP8-ify most of the files

consumer.py and conn.py will be done later after pending merges

1 files changed, 3 insertions, 1 deletions

diff --git a/kafka/producer.py b/kafka/producer.py
index 47e690b..589eb11 100644
--- a/kafka/producer.py
+++ b/kafka/producer.py
@@ -6,6 +6,7 @@ from kafka.protocol import create_message
 
 log = logging.getLogger("kafka")
 
+
 class SimpleProducer(object):
     """
     A simple, round-robbin producer. Each message goes to exactly one partition
@@ -18,6 +19,7 @@ class SimpleProducer(object):
 
     def send_messages(self, *msg):
         req = ProduceRequest(self.topic, self.next_partition.next(),
-            messages=[create_message(m) for m in msg])
+                             messages=[create_message(m) for m in msg])
+
         resp = self.client.send_produce_request([req])[0]
         assert resp.error == 0