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

Add a flush() call to the new producer API

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.9.0.0
    • Component/s: None
    • Labels:
      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-26_10:37:16.patch
          118 kB
          Jay Kreps
        3. KAFKA-1865_2015-02-25_17:15:26.patch
          118 kB
          Jay Kreps
        4. KAFKA-1865_2015-02-23_18:29:16.patch
          118 kB
          Jay Kreps
        5. KAFKA-1865_2015-02-22_16:26:46.patch
          45 kB
          Jay Kreps
        6. KAFKA-1865_2015-02-21_15:36:54.patch
          24 kB
          Jay Kreps

          Issue Links

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: