Uploaded image for project: 'Subscription Watch'
  1. Subscription Watch
  2. SWATCH-1164

Make partition key org_id for tally summary messages

    XMLWordPrintable

Details

    Description

      When sending TallySummary messages, set the message key to the org_id so that messages with the same org_id will be sent to the same topic partition, and will be processed in order by the same consumer. This would prevent remittance for a single org from getting updated in parallel.

      Investigate if there is something that we can do with logging to help with verification.

      Testing

      • Deploy into EE with multiple partitions
      • Run an hourly re-tally on all orgs that spans multiple hours.
      • Verification:
        • The log messages for a single org should be processed by the same consumer (check thread)
        • Locally we can use a Kafka UI tool to verify summary messages for a single org are all in the same topic partition.

      Attachments

        Activity

          People

            khowell@redhat.com Kevin Howell
            khowell@redhat.com Kevin Howell
            Aurobinda Nayak Aurobinda Nayak
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: