Description
KAFKA-3703 implements graceful close of consumers with a hard-coded timeout of 5 seconds. For consistency with the producer, add a close method with configurable timeout for Consumer.
public void close(long timeout, TimeUnit unit);
Since this is a public interface change, this change requires a KIP.
Attachments
Issue Links
- duplicates
-
KAFKA-3540 KafkaConsumer.close() may block indefinitely
-
- Resolved
-
- links to
- mentioned in
-
Page Loading...