Reverted more changes to reduce the diff

Author: rogaha

kafka/producer/base.py

@@ -231,7 +231,7 @@ def _send_messages(self, topic, partition, *msg, **kwargs):
                 resp = self.client.send_produce_request([req], acks=self.req_acks,
                                                         timeout=self.ack_timeout)
             except:
-                log.exception('Unable to send messages. Topics: {0} Number of msgs: {1}'.format(topic, len(messages)))
+                log.exception("Unable to send messages")
                 raise
         return resp
 

kafka/producer/simple.py

@@ -13,7 +13,7 @@
     BATCH_SEND_MSG_COUNT
 )
 
-log = logging.getLogger(__name__)
+log = logging.getLogger("kafka")
 
 
 class SimpleProducer(Producer):
@@ -57,9 +57,6 @@ def __init__(self, client, async=False,
                                              maxsize)
 
     def _next_partition(self, topic):
-        # for each message sent a partition is chosen, if random_start is True
-        # a random partition is selected, otherwise the next partition in the cycle
-        # is picked up
         if topic not in self.partition_cycles:
             if not self.client.has_metadata_for_topic(topic):
                 self.client.load_metadata_for_topics(topic)