We have three microservices here. The user service saves user information to the user table when a user is created and also creates an event, sending it to Kafka under the topic 'user_created'. Subsequently, we have two services that consume this event: the Transaction service retrieves the IDs and balance amounts of users for transaction processes and writes them to the 'user-wallet' table. If a transaction occurs, it emits an event named 'transaction_created', which is listened to by the user service to update the user's balance field. Our Notification service listens to the 'user_created' topic and sends a notification to the registered email using the Java Mail Sender. I also redis for caching in transaction service.
-
Notifications
You must be signed in to change notification settings - Fork 0
teomangungoren/sample-kafka
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published