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

Handle close gracefully for consumers and producers with acks=0

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.0.1
    • Fix Version/s: 0.10.2.0
    • Component/s: clients
    • Labels:
      None

      Description

      Outgoing writes may be discarded when a connection is closed. For instance, when running a producer with acks=0, a producer that writes data and closes the producer would expect to see all writes to complete if there are no errors. But close() simply closes the channel and socket which could result in outgoing data being discarded.

      This is also an issue in consumers which use commitAsync to commit offsets. Closing the consumer may result in commits being discarded because writes have not completed before close().

        Attachments

          Activity

            People

            • Assignee:
              rsivaram Rajini Sivaram
              Reporter:
              rsivaram Rajini Sivaram
            • Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: