Added the option of setting `max_wait_time` for Kafka Consumer sources.