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

Kafka streams lets the user call init() and close() on a state store, when inside Processors

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 2.2.0
    • streams
    • None

    Description

      When using a state store within Transform (and Processor and TransformValues), the user is able to call init() and close() on the state stores. Those APIs should only be called by kafka streams itself.

      If possible, it would be good to guard those APIs so that the user cannot call them.

      Attachments

        Issue Links

          is related to

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-7420 Global stores should be guarded as read-only for regular tasks

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Resolved
          relates to

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-8006 Guard calls to init() and close() within user code

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #6016

          Activity

            People

              nizhikov Nikolay Izhikov
              wushujames James Cheng
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: