Add a bunch of TODOs

Author: jeffwidman

docs/apidoc/kafka.rst

@@ -23,6 +23,7 @@ kafka.cluster module
     :show-inheritance:
 
 
+# TODO should this be pointing at client_async?
 kafka.client module
 -------------------
 

kafka/__init__.py

@@ -25,7 +25,7 @@ def emit(self, record):
 from kafka.conn import BrokerConnection
 from kafka.protocol import (
     create_message, create_gzip_message, create_snappy_message)
-from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner, Murmur2Partitioner
+from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner, Murmur2Partitioner  # TODO Murmur2Partitioner might be removable?
 from kafka.structs import TopicPartition, OffsetAndMetadata
 from kafka.serializer import Serializer, Deserializer
 

kafka/partitioner/hashed.py

@@ -26,6 +26,7 @@ def partition(self, key, partitions=None):
         return partitions[idx]
 
 
+# TODO is this already done?
 # Default will change to Murmur2 in 0.10 release
 HashedPartitioner = LegacyPartitioner
 

kafka/producer/buffer.py

@@ -238,6 +238,7 @@ def queued(self):
         with self._lock:
             return len(self._waiters)
 
+# TODO should this be removed or finished?
 '''
 class BufferPool(object):
     """

kafka/protocol/struct.py

@@ -65,6 +65,7 @@ def __eq__(self, other):
                 return False
         return True
 
+# TODO should this be removed or finished?
 """
 class MetaStruct(type):
     def __new__(cls, clsname, bases, dct):