[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885795#comment-16885795 ]
Richard Yu edited comment on KAFKA-7711 at 7/16/19 3:01 AM: ------------------------------------------------------------ [~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? Edit: Got it somewhat mixed up. There had been issues with Kafka's send API in the past. For example, KAFKA-6705. But not the flush() API. It might be good to have something like it though. was (Author: yohan123): [~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)