[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504377#comment-16504377 ]
Chia-Ping Tsai commented on KAFKA-6608: --------------------------------------- {code:java} /** * @see KafkaConsumer#close(long, TimeUnit) */ @Deprecated void close(long timeout, TimeUnit unit);{code} Given the java.time.Duration has been introduced into Consumer, should we do the similar change to Producer#close(long, TimeUnit)? > Add TimeoutException to KafkaConsumer#position() > ------------------------------------------------ > > Key: KAFKA-6608 > URL: https://issues.apache.org/jira/browse/KAFKA-6608 > Project: Kafka > Issue Type: Improvement > Components: consumer > Reporter: Richard Yu > Assignee: Richard Yu > Priority: Blocker > Labels: kip > Fix For: 2.0.0 > > > In KAFKA-4879, Kafka Consumer hangs indefinitely due to Fetcher's {{timeout}} > being set to {{Long.MAX_VALUE}}. While fixing this issue, it was pointed out > that if a timeout was added to methods which commits offsets synchronously, a > stricter control on time could be achieved. > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75974886 -- This message was sent by Atlassian JIRA (v7.6.3#76005)