kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "kun du (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-7711) Add a bounded flush() API to Kafka Producer
Date Thu, 06 Dec 2018 19:55:00 GMT
kun du created KAFKA-7711:

             Summary: 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

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

View raw message