I upgraded the python producer to use the new protocol. This helps avoid any producer/consumer mismatches. Could anyone using that code if they could take a look at the patch and report any problems that would be fantastic! https://issues.apache.org/jira/browse/KAFKA-162 -Jay