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

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

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Pending Closed
    • Affects Version/s: 0.8.2.0
    • Fix Version/s: 0.9.0.0
    • Component/s: clients, producer
    • Labels:
      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_2015-02-17_16:41:19.patch
          6 kB
          Parth Brahmbhatt
        3. KAFKA-1660_2015-03-02_10:41:49.patch
          7 kB
          Parth Brahmbhatt
        4. KAFKA-1660.patch
          17 kB
          Jiangjie Qin
        5. KAFKA-1660_2015-03-08_21:14:50.patch
          19 kB
          Jiangjie Qin
        6. KAFKA-1660_2015-03-09_12:56:39.patch
          33 kB
          Jiangjie Qin
        7. KAFKA-1660_2015-03-25_10:55:42.patch
          37 kB
          Jiangjie Qin
        8. KAFKA-1660_2015-03-27_16:35:42.patch
          47 kB
          Jiangjie Qin
        9. KAFKA-1660_2015-04-07_18:18:40.patch
          87 kB
          Jiangjie Qin
        10. KAFKA-1660_2015-04-08_14:01:12.patch
          99 kB
          Jiangjie Qin
        11. KAFKA-1660_2015-04-10_15:08:54.patch
          103 kB
          Jiangjie Qin
        12. KAFKA-1660_2015-04-16_11:35:37.patch
          111 kB
          Jiangjie Qin
        13. KAFKA-1660_2015-04-20_17:38:22.patch
          116 kB
          Jiangjie Qin
        14. KAFKA-1660_2015-04-29_16:58:43.patch
          107 kB
          Jiangjie Qin
        15. KAFKA-1660_2015-04-29_17:37:51.patch
          109 kB
          Jiangjie Qin
        16. KAFKA-1660_2015-05-12_14:28:53.patch
          114 kB
          Jiangjie Qin

          Issue Links

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: