comply with new changes in kafka-python