257 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
votes
1
answer
41
views
How can i manage offsets in Kafka at Message Level
This is my code :
@retry(stop=stop_after_attempt(3), wait=wait_fixed(2))
def kafka_consumer(self):
"""Consume messages from Kafka with retry logic."""
...
1
vote
1
answer
43
views
Design Review: Handling Dynamic Event Processing in Azure Function App
I'm building a piece of software responsible for processing different types of events from my system. This component is hosted as an Azure Function App, triggered by an Azure Storage Queue. The ...
- 115
0
votes
0
answers
63
views
How to handle an authorization policy in both queries and commands in CQRS?
I'm implementing a restaurant management micro-service using CQRS pattern.
The read and write databases are separated and eventually become consistent by async events using an event bus.
Now I want to ...
- 131
2
votes
1
answer
419
views
How to achieve distributed transaction consistency in a microservices architecture without using 2PC?
In a microservice architecture, each service typically manages its own database and executes operations independently. However, when dealing with business processes that span multiple microservices, ...
- 494
0
votes
1
answer
196
views
In an event driven architecture (websockets, pub sub, etc), do the clients and server constantly check for new messages? How does it work?
I have read a number of articles describing how websockets and pub sub architectures work at a high level.
I get that with websockets a connection is persisted between a client and a server to send ...
- 1,899
1
vote
1
answer
665
views
Message ordering in event driven architecture
Consider there are 3 microservices - s1, s2 and s3.
s1 sends message m1.
s2 consumes message m1, applies some business logic and then sends message m2.
The problem is that s3 receives message m2 ...
- 27
1
vote
1
answer
57
views
EDA Choreography - keep overall state
In an event driven architecture using choreogeaphy model, how do we keep current, global state of the process?
Lets say we have a process where many services p1,...,pn transition many states s1,...,...
- 15.5k
0
votes
2
answers
100
views
Axon v4.9.5 startup problem, came out of nowhere
I've built my CQRS project Core-API, where i have declared events, and commands, also the AxonConfig (just some xStream allowtypesByWildcard)
Till this point, everythings works fine
I created the ...
1
vote
1
answer
99
views
How to maintain control of numerous event racing scenarios in a platform of growing complexity?
I have a Voucher Service which listens to incoming sales, and updates vouchers based on what has been purchased/returned etc.
So we consume a SaleCompletedEvent, which may put vouchers into a '...
- 4,638
1
vote
0
answers
109
views
How can I run a kafka consumer in a django project so that messages will passed to django project
I am running my kafka consumer (from the confluent_kafka library) in a separate django management command. (I did this because I couldn't find a way of running a kafka consumer within the runserver ...
- 11
0
votes
0
answers
197
views
Sync data from one application to another
We have an application A which has its own domain model and database (SQLSERVER). Another application B has its own domain model and database. We want to create another application C which is to ...
- 49
0
votes
1
answer
1k
views
Event Bridge Targets
I'm investigating the use of event bridge as we are currently using Kafka and we want to confirm it's the best fit for us.
However, I haven't used event bridge before and I'm a little confused with ...
- 119
0
votes
1
answer
275
views
Redis Streams, Event Driven Architecture and Schema Evolution
I'm really interested in using Redis Streams as the messaging backbone for a platform utilising event driven architecture in place of Kafka for the following reasons:
Lower cost
Drastically lower ...
- 688
0
votes
1
answer
116
views
EDA with EventSourcing order of events guarantee with Kafka
Let's say I have an Order and a Product.
Whenever product is created I publish PRODUCT_CREATE event and for the order it is ORDER_CREATE
If I use Kafka ( or any message broker ) should I have 1 queue ...
- 25
1
vote
2
answers
614
views
Microservices streaming data vs events
In microservices architecture, you can follow an event driven architecture where you want to publish events, doubt it’s about size of the payload.
What is a reasonable amount of data to be there?
You ...
- 2,189
1
vote
0
answers
1k
views
Creating an event driven architecture using Django
I would like to create an event driven architecture in Django. Every time a database record is created, updated or deleted, i would like to create and event, posting it to a queue ( like kafka, sqs, ...
- 8,446
1
vote
1
answer
335
views
How to "replay" past integration events to replicate current state in a new context
I'm quite new to DDD and Event Driven architectures. And after searching this issue I did not manage to get a clear answer by myself, so I'll appreciate if someone can clarify this.
Suppose I ...
- 73
1
vote
1
answer
118
views
Migrating an asynchronous businness flow to an event-driven system
In the effort to redesign an asynchronous flow based functional service to an event driven one, we have come up with changes on different part of this system. The service receives various statuses ...
- 2,932
1
vote
1
answer
1k
views
How multiple Kafka Consumers in the same consumer group read messages from one partition in the topic?
I would like to know about how the consumers in the same consumer group read the messages from one topic which has only one partition.
For example, I have 3 consumers in one consumer group and that ...
- 45
2
votes
1
answer
192
views
Retry logic when a partial update failed
I think that it is a general problem and it is not related with the using technologies. So, please consider the problem itself.
I am storing data in Couchbase like below format
productId is document ...
- 471
0
votes
1
answer
2k
views
Zephyr Project Event Handling
I am working on an event driven portion of a project utilizing the use of the Zephyr Project. I am relatively new to Zephyr so I apologize if I am going about this wrong. My goal is to have a forever ...
0
votes
2
answers
308
views
How to do versioning of Custom Serdes objects in Kafka Stream while using processor API during Rolling Upgrade
How to achieve handling multiple versions of UserDetailDto while processing it from Topic-A to Topic-B with Kafka stream using processor API.
Existing instance/replica of aggregation service should ...
- 81
0
votes
1
answer
963
views
Webhook (Push) vs Asynchronous Queue (Push) Architecture [closed]
When building webhooks, it's a best practice for the consumer of the webhook (e.g. the receiver of the webhook) to immediately drop any messages received into a queue to prevent it from "backing ...
- 1,462
4
votes
3
answers
2k
views
Flutter BLoC - Bloc vs Cubit event driven state management advantages
What are the actual advantage(s) of Bloc over Cubit?
In addition to traceability (which you can also achieve with appropriate logging in Cubit), and advanced event transformations (I can't think of ...
- 2,526