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

Streams should not suspend tasks twice

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 1.0.0
    • 0.11.0.1, 1.0.0
    • streams
    • None

    Description

      Currently, Streams suspends tasks on rebalance and closes suspended tasks if not reassigned. During close, suspend() is called a second time, also calling Processor.close() for all nodes again.

      It would be safer to only call suspend() once in case users have non-idempotent operations in Processor.close() method and might thus fail. (cf. KAFKA-5167)

      Attachments

        Issue Links

          Activity

            People

              mjsax Matthias J. Sax
              mjsax Matthias J. Sax
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: