
In kafka 0.9.5 the partition key needs to be a six.binary_type which is a str in Python 2.6 Change-Id: I423694d635521d286bfdafc2172b31f3dca21860
In kafka 0.9.5 the partition key needs to be a six.binary_type which is a str in Python 2.6 Change-Id: I423694d635521d286bfdafc2172b31f3dca21860