mumrah/kafka-python — pull request #19 by mahendra (2013-05-27 05:58:04+00:00)
Title: Minor bug fixes

* When you initiate a producer with a non-existant queue, the queue is
created. However this partition info is not reflected in KafkaClient()
immediately. So, we wait for a second and try loading it again.

Without this fix, if we do producer.send_messages() after creating a new
queue, the library will throw a StopIteration exception.

* In SimpleConsumer(), the defaults are not as mentioned in the comments.
Fix this (or do we change the documentation?)