The consumer close code needs to block until the fetch sessions are closed. `KafkaConsumer` has `close()` and `close(long timeout, TimeUnit timeUnit)`. In the case of the latter one, we don't want to wait longer than the specified time.
[ Full content available at: https://github.com/apache/kafka/pull/5407 ] This message was relayed via gitbox.apache.org for [email protected]
