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

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

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

            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: