Multi-Tenant Transactional Outbox Pattern For Event Publishing

A method comprising:

• initiating, by a particular processing thread for a particular microservice for a particular tenant, execution of an atomic transaction, the atomic transaction comprising (a) executing a database transaction by adding, modifying, or deleting a value in a database instance and (b) logging, to an event outbox associated with the particular tenant, information corresponding to the database transaction;
• receiving, by the particular processing thread, confirmation of execution of the atomic transaction;
• responsive to receiving the confirmation of the execution of the atomic transaction, publishing, by the particular processing thread in a particular stream partition, a notification corresponding to the execution of the atomic transaction, wherein the notification comprises information that can be used to identify the event outbox storing the information corresponding to the database transaction;
• receiving, by an event publisher subscribed to the particular stream partition, the notification corresponding to the execution of the atomic transaction;
• retrieving, by the event publisher from the event outbox, the information corresponding to the database transaction;
• and
• publishing, by the event publisher, an event based on the information corresponding to the database transaction,
• wherein the method is executed by at least one device including a hardware processor.

A system comprising:

• at least one device including a hardware processor;
• the system being configured to perform operations comprising:
• initiating, by a particular processing thread for a particular microservice for a particular tenant, execution of an atomic transaction, the atomic transaction comprising (a) executing a database transaction by adding, modifying, or deleting a value in a database instance and (b) logging, to an event outbox associated with the particular tenant, information corresponding to the database transaction;
• receiving, by the particular processing thread, confirmation of execution of the atomic transaction;
• responsive to receiving the confirmation of the execution of the atomic transaction, publishing, by the particular processing thread in a particular stream partition, a notification corresponding to the execution of the atomic transaction, wherein the notification comprises information that can be used to identify the event outbox storing the information corresponding to the database transaction;
• receiving, by an event publisher subscribed to the particular stream partition, the notification corresponding to the execution of the atomic transaction;
• retrieving, by the event publisher from the event outbox, the information corresponding to the database transaction;
• and
• publishing, by the event publisher, an event based on the information corresponding to the database transaction.