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

Refactor the main loop to process more than one record of one task at a time

    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.6.0
    • Component/s: streams
    • Labels:
      None

      Description

      Our current main loop is implemented as the following:

      1. Loop over all tasks that have records to process, each time process one record at a time.
      2. After finish processing one record from each task, check if commit / punctuate / pool etc is needed.

      Because we process one record at a time from the task and then moves on to the next task, we are effectively spending lots of time on context switches. Maybe we can first investigate what if we just have each task to be hosted by an individual thread, and see if the context switch cost is is not worse already (which means our current implementation is already a baseline). If that's true we can consider working on one task at a time, and see if it is more efficient.

      For num.Iterations:
      1. process one record from each of the tasks thread owns.
      2. check if commit / punctuate / poll / etc needed.

      But in 1) above we process tasks A,B,C,A,B,C,... and effectively we are introducing context switches within the thread as it needs to load the task variables etc for each record processed.

      What I was thinking is to process tasks as A,A,A,B,B,B,C,C,C... so that we can reduce the context switches.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                guozhang Guozhang Wang
                Reporter:
                guozhang Guozhang Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: