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

Investigate propagating subscription state updates via queues

    XMLWordPrintableJSON

Details

    Description

      We are mostly using the queues for interaction between application thread and background thread, but the subscription object is shared between the threads, and it is updated directly without going through the queues.

      The way we allow updates to the subscription state from both threads is definitely not right, and will bring trouble. Places like the assign() is probably the most obvious, where we send an event to the background to commit, but then update the subscription in the foreground right away.

      It seems sensible to aim for having all updates to the subscription state in the background, triggered from the app thread via events (and I think we already have related events for all updates, just that the subscription state was left out in the app thread).

      Attachments

        Issue Links

          Activity

            People

              cadonna Bruno Cadonna
              lucasbru Lucas Brutschy
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated: