67 questions
Advice
0
votes
0
replies
33
views
Storing Domain Events directly in Outbox table vs mapping to Integration Events in Java/Spring (DDD based Microservices)
I have a Spring Boot / Java application following Domain-Driven Design and Event-Driven Architecture.
In my domain service, I create a ReservationCreatedEvent (a domain event) and publish it:
...
1
vote
1
answer
68
views
Should I create a separate Integration Event when using the Outbox Pattern in a DDD-based microservice? [closed]
I’m building a Java microservice using Spring Boot 3.5.7, Kafka, and the Outbox Pattern.
In my domain layer, I raise a domain event:
package com.turkcell.reservation_service.domain.event;
import com....
0
votes
0
answers
37
views
Parallel sagas listening to the same channel are encountering a race condition
I'm attempting to develop an understanding of the Saga and Outbox patterns, and am working on development now. I'm using RabbitMQ and NestJS. I've got three services, Orders, Inventory, and Shipping. ...
- 73
0
votes
0
answers
224
views
How to implement transactional outbox pattern with AWS Lambda and PostgreSQL
I use AWS Lambda function to respond to HTTP requests.
The function stores some data in a PostgreSQL database.
To reliably notify interested parties of the changes, I use transactional outbox pattern.
...
- 1,119
0
votes
0
answers
66
views
Azure Cosmos DB for Mongo data consistency
I tried to implement the transactional outbox pattern in my Spring Boot app.
I'm using Azure CosmosDB for Mongo, which does not support transactions across collections.
When I attempted to perform ...
- 11
-1
votes
1
answer
140
views
How to manage MassTransit Outbox pattern db schemas across microservices [closed]
I have many microservices and each have its own DbContext (one per microservice) and model. The db separation is by Schema in the same database. I want to use MassTransit Outbox pattern in all my ...
- 4,211
1
vote
2
answers
292
views
Transactional outbox distributed lock fencing confusion
I wish to implement the transactional outbox pattern in a system that uses a database table as a transactional outbox in concert with Kafka in order to guarantee exactly-once delivery of my messages ...
- 3,744
0
votes
1
answer
179
views
Microservices inbox-outbox pattern
I have a question I'm curious about. Let's say we are developing a microservice social media application (I chose this topic for practical purposes :)). I'm using the inbox-outbox pattern to ensure ...
- 11
0
votes
0
answers
289
views
Mass Transit : EF Core outbox not persisting messages
I have been googling this for a while and can't seem to find a solution, this seems to line up with the Mass Transit docs. Mass transit works perfectly in my project but as soon as I add the SQL ...
- 2,326
1
vote
0
answers
345
views
Building a "real-time" outbox pattern on Python / SQLALchemy
I have create a outbox messages in my FastAPI/SQLAlchemy/Postgres application. The application is hosted in GCP. Now I need to publish this events, "reading" from the outbox table. I need to ...
- 8,446
7
votes
2
answers
4k
views
Inbox pattern and outbox pattern
I don't see the difference between the Inbox pattern and the Outbox pattern.
the Inbox pattern saves messages in a database. The Outbox pattern too, so what is the difference?
1
vote
2
answers
968
views
Is it possible to use MassTransit transactional outbox with multiple db contexts?
I am trying to build a modular monolith application where each module is defined in its own class library project. I would like to utilize a single SQL Server 2019 database and create a separate db ...
- 75
0
votes
1
answer
261
views
NServiceBus Outbox exactly once processing
Reading the documentation, it says:
Due to possible failures, a given message may be sent multiple times. For example, if an exception is thrown in step 3 (failure to
update outbox storage) the ...
1
vote
2
answers
593
views
Outbox pattern with Spring Integration
We want to implement an Outbox pattern by using spring integration.
Starting from this example, we came up with this simpeler solution:
protected IntegrationFlowDefinition<?> buildFlow() {
...
- 531
3
votes
1
answer
3k
views
Transactional outbox confusion
It is common that a service may need to combine database writes with publishing events and/or sending commands.
It appears the only way to guarantee this is via the use of a Transactional Outbox where ...
- 17.7k
2
votes
1
answer
1k
views
In-Memory Outbox with MassTransit
We wish to implement an outbox pattern at the producer level to ensure delivery to the Azure Service Bus, i.e. hold the message in the outbox only till the service bus is unavailable or down and send ...
- 139
0
votes
0
answers
194
views
run debezum source conncector with custom single message transformer
It is being developed to attach smt (single message transforms) to the debezium mysql source connector. I implemented debezium smt by referring to the documentation, put the smt and mysql source ...
- 61
0
votes
3
answers
3k
views
Outbox Pattern vs Debezium
I am trying to understand if there's a fundamental difference between what the 2 are trying to achieve. I have a use case of landing my postgres data to data lake, and these are the 2 paved-road ...
- 4,453
0
votes
1
answer
842
views
MassTransit Transactional Outbox Default Isolation Level
I've been using the MassTransit v8.0.13 Transactional Outbox for a few months, but now I'm wondering about the default transactional level set on it. I'm using Postgres and when I setup the ...
- 17
1
vote
1
answer
673
views
Masstransit transactiona outbox + Masstransit mediator
I am trying to use the Masstransit library, implementing the mediator provided by Masstransit to communicate my controller layer with the application layer, and also adding the transactional outbox ...
1
vote
1
answer
593
views
MassTransit Transactional Outbox Isolation Level per Consumer
I have a consumer where I begin a serializable transaction.
public class Consumer : IConsumer<Message>
{
public async Task Consume(ConsumeContext<Message> context)
{
...
- 17
0
votes
1
answer
607
views
how to implement outbox like pattern with third party api
I am implementing integration with a third party system, that I don't have a control over it, and use rabbitmq as message queue to publish a message after doing some updates on the third party system, ...
- 740
1
vote
1
answer
397
views
How is Apache Camel making sure there are no two masters?
My starting point is the actually the outbox pattern.
To make sure the message in an outbox in only relayed once we only have one replica of the outbox service available in our k8s cluster. To be ...
- 3,731
7
votes
1
answer
3k
views
Comparing CDC vs Outbox Pattern for creating event streams
I'm working on creating event streams using Outbox pattern. I would like to know why would one go for Outbox pattern instead of using CDC on the required tables?
Pros of using CDC directly:
The ...
3
votes
1
answer
2k
views
MongoDb, RabbitMq and outbox pattern
I have a question about mongodb and outbox pattern (and i'm quite newbie in mongo).
I am working on application, that uses mongodb as primary database.
I have some use cases, in which i need to save ...
- 31