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

Guard race conditions in TopologyBuilder

    XMLWordPrintableJSON

    Details

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

      Description

      The user specified TopologyBuilder is shared among all stream threads to build the processor topology instance, one for each thread. It public functions that can be accessed by the threads is not synchronized, and we need to double check if it could cause race conditions, and if yes guard against these concurrent access.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                damianguy Damian Guy
                Reporter:
                guozhang Guozhang Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: