[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712789#comment-16712789 ]
Stanislav Kozlovski commented on KAFKA-7711: -------------------------------------------- This sounds good to me. Thanks for opening the JIRA, [~kdu] > 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 > Reporter: kun du > Priority: Minor > > 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.3#76005)