python kafka consumer graceful shutdown