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

Add a request timeout to NetworkClient

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • None
    • 0.9.0.0
    • None
    • None

    Description

      Currently NetworkClient does not have a timeout setting for requests. So if no response is received for a request due to reasons such as broker is down, the request will never be completed.
      Request timeout will also be used as implicit timeout for some methods such as KafkaProducer.flush() and kafkaProducer.close().
      KIP-19 is created for this public interface change.
      https://cwiki.apache.org/confluence/display/KAFKA/KIP-19+-+Add+a+request+timeout+to+NetworkClient

      Attachments

        1. KAFKA-2120_2015-07-27_15:31:19.patch
          80 kB
          Mayuresh Gharat
        2. KAFKA-2120_2015-07-29_15:57:02.patch
          83 kB
          Mayuresh Gharat
        3. KAFKA-2120_2015-08-10_19:55:18.patch
          123 kB
          Mayuresh Gharat
        4. KAFKA-2120_2015-08-12_10:59:09.patch
          126 kB
          Mayuresh Gharat
        5. KAFKA-2120_2015-09-03_15:12:02.patch
          144 kB
          Mayuresh Gharat
        6. KAFKA-2120_2015-09-04_17:49:01.patch
          175 kB
          Mayuresh Gharat
        7. KAFKA-2120_2015-09-09_16:45:44.patch
          188 kB
          Mayuresh Gharat
        8. KAFKA-2120_2015-09-09_18:56:18.patch
          191 kB
          Mayuresh Gharat
        9. KAFKA-2120_2015-09-10_21:38:55.patch
          194 kB
          Mayuresh Gharat
        10. KAFKA-2120_2015-09-11_14:54:15.patch
          196 kB
          Mayuresh Gharat
        11. KAFKA-2120_2015-09-15_18:57:20.patch
          206 kB
          Mayuresh Gharat
        12. KAFKA-2120_2015-09-18_19:27:48.patch
          209 kB
          Mayuresh Gharat
        13. KAFKA-2120_2015-09-28_16:13:02.patch
          210 kB
          Mayuresh Gharat
        14. KAFKA-2120.patch
          78 kB
          Mayuresh Gharat

        Issue Links

          duplicates

          Bug - A problem which impairs or prevents the functions of the product. KAFKA-1788 producer record can stay in RecordAccumulator forever if leader is no available

          • Major - Major loss of function.
          • Resolved

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-1835 Kafka new producer needs options to make blocking behavior explicit

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #1061

          Activity

            People

              mgharat Mayuresh Gharat
              becket_qin Jiangjie Qin
              Jason Gustafson Jason Gustafson
              Votes:
              2 Vote for this issue
              Watchers:
              18 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: