Let's take a use case where the client tries to perform a certain operation, and we are using Kafka as an eventstore to capture all the messages that are being passed. In this case, we have the user management service, which could be a microservice responsible for managing all user requests. We will start with identifying the topics for Kafka based on user events, which could be one of the following:
- UserCreatedEvent
- UserUpdatedEvent
- UserDeletionEvent
- UserLoggedinEvent
- UserRoleUpdatedEvent
These events will, ideally, be published by the User Management Service, and all microservices will consume these events. The following diagram shows the user request flow:
