PEP8-ify most of the files

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

1 files changed, 34 insertions, 11 deletions

diff --git a/kafka/common.py b/kafka/common.py
index 447684f..9aab8fc 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -5,26 +5,49 @@ from collections import namedtuple
 ###############
 
 # Request payloads
-ProduceRequest = namedtuple("ProduceRequest", ["topic", "partition", "messages"])
-FetchRequest = namedtuple("FetchRequest", ["topic", "partition", "offset", "max_bytes"])
-OffsetRequest = namedtuple("OffsetRequest", ["topic", "partition", "time", "max_offsets"])
-OffsetCommitRequest = namedtuple("OffsetCommitRequest", ["topic", "partition", "offset", "metadata"])
+ProduceRequest = namedtuple("ProduceRequest",
+                            ["topic", "partition", "messages"])
+
+FetchRequest = namedtuple("FetchRequest",
+                          ["topic", "partition", "offset", "max_bytes"])
+
+OffsetRequest = namedtuple("OffsetRequest",
+                           ["topic", "partition", "time", "max_offsets"])
+
+OffsetCommitRequest = namedtuple("OffsetCommitRequest",
+                                 ["topic", "partition", "offset", "metadata"])
+
 OffsetFetchRequest = namedtuple("OffsetFetchRequest", ["topic", "partition"])
 
 # Response payloads
-ProduceResponse = namedtuple("ProduceResponse", ["topic", "partition", "error", "offset"])
-FetchResponse = namedtuple("FetchResponse", ["topic", "partition", "error", "highwaterMark", "messages"])
-OffsetResponse = namedtuple("OffsetResponse", ["topic", "partition", "error", "offsets"])
-OffsetCommitResponse = namedtuple("OffsetCommitResponse", ["topic", "partition", "error"])
-OffsetFetchResponse = namedtuple("OffsetFetchResponse", ["topic", "partition", "offset", "metadata", "error"])
+ProduceResponse = namedtuple("ProduceResponse",
+                             ["topic", "partition", "error", "offset"])
+
+FetchResponse = namedtuple("FetchResponse", ["topic", "partition", "error",
+                                             "highwaterMark", "messages"])
+
+OffsetResponse = namedtuple("OffsetResponse",
+                            ["topic", "partition", "error", "offsets"])
+
+OffsetCommitResponse = namedtuple("OffsetCommitResponse",
+                                  ["topic", "partition", "error"])
+
+OffsetFetchResponse = namedtuple("OffsetFetchResponse",
+                                 ["topic", "partition", "offset",
+                                  "metadata", "error"])
+
 BrokerMetadata = namedtuple("BrokerMetadata", ["nodeId", "host", "port"])
-PartitionMetadata = namedtuple("PartitionMetadata", ["topic", "partition", "leader", "replicas", "isr"])
 
-# Other useful structs 
+PartitionMetadata = namedtuple("PartitionMetadata",
+                               ["topic", "partition", "leader",
+                                "replicas", "isr"])
+
+# Other useful structs
 OffsetAndMessage = namedtuple("OffsetAndMessage", ["offset", "message"])
 Message = namedtuple("Message", ["magic", "attributes", "key", "value"])
 TopicAndPartition = namedtuple("TopicAndPartition", ["topic", "partition"])
 
+
 class ErrorMapping(object):
     # Many of these are not actually used by the client
     UNKNOWN                   = -1