I am looking at building a reactive api on top of Kafka. This API produces event to Kafka topic. I want to add a unique session id into the payload. The data gets transformed as it goes through different stages of a pipeline. I want to specify a final topic where I want the api to know that the processing was successful. The API should give different status at each part of the pipeline. At the ingestion, the API responds with "submitted" During the progression, the API returns "in progress" After successful completion, the API returns "Success"
Couple of questions: 1. Is this feasible? 2. I was looking at project reactor (https://projectreactor.io) where the docs talk about event bus. I wanted to see if I can implement a consumer that points to the "end" topic and throws an event into the event bus. Since I would know the session ID, I can process the request accordingly. Appreciate your inputs. - Shekar
