[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885795#comment-16885795 ]
Richard Yu commented on KAFKA-7711: ----------------------------------- [~hachikuji] I think I've seen this issue come up multiple times in the past. Not sure exactly which issue numbers. Do you think this is a issue that really needs to be tackled? > Add a bounded flush() API to Kafka Producer > -------------------------------------------- > > Key: KAFKA-7711 > URL: https://issues.apache.org/jira/browse/KAFKA-7711 > Project: Kafka > Issue Type: Improvement > Components: producer > Reporter: kun du > Priority: Minor > Labels: needs-kip > > Currently the call to Producer.flush() can be hang there for indeterminate > time. > It is a good idea to add a bounded flush() API and timeout if producer is > unable to flush all the batch records in a limited time. In this way the > caller of flush() has a chance to decide what to do next instead of just wait > forever. -- This message was sent by Atlassian JIRA (v7.6.14#76016)