Python Kafka Consumer Commit