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

Add a flush() call to the new producer API

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 0.9.0.0
    • None
    • None

    Description

      The postconditions of this would be that any record enqueued prior to flush() would have completed being sent (either successfully or not).

      An open question is whether you can continue sending new records while this call is executing (on other threads).

      We should only do this if it doesn't add inefficiencies for people who don't use it.

      Attachments

        1. KAFKA-1865.patch
          13 kB
          Jay Kreps
        2. KAFKA-1865_2015-02-21_15:36:54.patch
          24 kB
          Jay Kreps
        3. KAFKA-1865_2015-02-22_16:26:46.patch
          45 kB
          Jay Kreps
        4. KAFKA-1865_2015-02-23_18:29:16.patch
          118 kB
          Jay Kreps
        5. KAFKA-1865_2015-02-25_17:15:26.patch
          118 kB
          Jay Kreps
        6. KAFKA-1865_2015-02-26_10:37:16.patch
          118 kB
          Jay Kreps

        Issue Links

          Activity

            People

              jkreps Jay Kreps
              jkreps Jay Kreps
              Votes:
              0 Vote for this issue
              Watchers:
              9 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: