https://github.com/mumrah/kafka-python/blob/master/kafka/consumer/simple.py#L255 there is a bug when get_partition_info is True, so should change to: if get_partition_info: return None, None else: return None