Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1660

Ability to call close() with a timeout on the Java Kafka Producer.

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Pending Closed
    • 0.8.2.0
    • 0.9.0.0
    • clients, producer
    • None

    Description

      I would like the ability to call close with a timeout on the Java Client's KafkaProducer.

      Workaround

      Currently, it is possible to ensure that close will return quickly by first doing a future.get(timeout) on the last future produced on each partition, but this means that the user has to define the partitions up front at the time of send and track the returned future's

      Attachments

        1. KAFKA-1660_2015-05-12_14:28:53.patch
          114 kB
          Jiangjie Qin
        2. KAFKA-1660_2015-04-29_17:37:51.patch
          109 kB
          Jiangjie Qin
        3. KAFKA-1660_2015-04-29_16:58:43.patch
          107 kB
          Jiangjie Qin
        4. KAFKA-1660_2015-04-20_17:38:22.patch
          116 kB
          Jiangjie Qin
        5. KAFKA-1660_2015-04-16_11:35:37.patch
          111 kB
          Jiangjie Qin
        6. KAFKA-1660_2015-04-10_15:08:54.patch
          103 kB
          Jiangjie Qin
        7. KAFKA-1660_2015-04-08_14:01:12.patch
          99 kB
          Jiangjie Qin
        8. KAFKA-1660_2015-04-07_18:18:40.patch
          87 kB
          Jiangjie Qin
        9. KAFKA-1660_2015-03-27_16:35:42.patch
          47 kB
          Jiangjie Qin
        10. KAFKA-1660_2015-03-25_10:55:42.patch
          37 kB
          Jiangjie Qin
        11. KAFKA-1660_2015-03-09_12:56:39.patch
          33 kB
          Jiangjie Qin
        12. KAFKA-1660_2015-03-08_21:14:50.patch
          19 kB
          Jiangjie Qin
        13. KAFKA-1660.patch
          17 kB
          Jiangjie Qin
        14. KAFKA-1660_2015-03-02_10:41:49.patch
          7 kB
          Parth Brahmbhatt
        15. KAFKA-1660_2015-02-17_16:41:19.patch
          6 kB
          Parth Brahmbhatt
        16. KAFKA-1660.patch
          3 kB
          Parth Brahmbhatt

        Issue Links

        is duplicated by

        New Feature - A new feature of the product, which has yet to be developed. KAFKA-1934 Add a shutdownNow() call to new producer

        • Major - Major loss of function.
        • Resolved

        Activity
          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            becket_qin Jiangjie Qin
            AndrewStein Andrew Stein
            Jay Kreps Jay Kreps
            Votes:
            1 Vote for this issue
            Watchers:
            8 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment