updates for kafka-python usage