Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-458

Close in KafkaSystemProducer should flush all source buffers

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 0.9.0
    • kafka

    Description

      I noticed that calling KafkaSystemProducer.stop does not flush any outstanding messages in the sourceBuffers array. Calling close should flush all buffers. Without this, shutting down can cause messages to be dropped.

      Attachments

        1. SAMZA-458.patch
          5 kB
          Yan Fang
        2. SAMZA-458.1.patch
          4 kB
          Yan Fang
        3. SAMZA-458.2.patch
          4 kB
          Chris Riccomini
        4. SAMZA-458.3.patch
          4 kB
          Chris Riccomini

        Issue Links

          relates to

          Sub-task - The sub-task of the issue SAMZA-448 Pass config from JobRunner to JobCoordinator via ConfigStream

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              closeuris Yan Fang
              criccomini Chris Riccomini
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: