आपको डेटाबेस अपडेट करना है और एक event भी publish करना है। इन दोनों को बेमेल होने से आप कैसे रोकेंगे?

transactional outbox pattern इस्तेमाल करें: state बदलने वाले उसी ट्रांजैक्शन में event को एक outbox टेबल में लिखें, फिर एक अलग relay उसे poll करे या log से पढ़े और publish करके sent मार्क कर दे। इस तरह एक ही commit होता है, तो न कभी event के बिना row बचेगी और न row के बिना event। relay at least once delivery देता है, इसलिए consumers को फिर भी idempotent होना चाहिए।

फंदा यह है कि डेटाबेस commit और broker publish दो अलग सिस्टम हैं, इसलिए आप जो भी क्रम चुनें, उसकी एक नाकामी बनी रहती है। पहले publish करें तो ट्रांजैक्शन roll back हो सकता है, और consumers ऐसी चीज़ पर काम कर बैठते हैं जो हुई ही नहीं। पहले commit करें तो publish से पहले प्रोसेस मर सकती है, तो event गुम हो जाता है और उसे कोई दोबारा नहीं भेजता। outbox pattern यह खाई मिटा देता है: event row उसी ट्रांजैक्शन के अंदर outbox टेबल में insert होती है जिसमें बिज़नेस बदलाव होता है, तो या तो दोनों टिकते हैं या कोई नहीं। फिर एक relay unsent rows क्रम में पढ़कर publish करता है और उन्हें sent मार्क करता है, और publish के बीच crash हो जाए तो वह बस दोबारा publish कर देता है, इसीलिए consumers को idempotent होना ज़रूरी है। अगर मैं Postgres पर हूं और कम polling चाहता हूं, तो Debezium जैसी चीज़ से write ahead log पर change data capture लगाता हूं, जो वही गारंटी कम खुद के लिखे कोड में दे देती है। जिन ऑपरेशनल बातों की योजना बनानी चाहिए वे हैं outbox की छंटाई और relay lag की निगरानी, क्योंकि जो outbox खाली होना बंद कर दे, वह एप्लिकेशन की तरफ से पूरी तरह स्वस्थ दिखता है।