Here's another Reactive API: https://github.com/akka/reactive-kafka
It was developed by Software Mill <https://softwaremill.com/> and it's now being integrated with Akka <http://akka.io>. dean Dean Wampler, Ph.D. Author: Programming Scala, 2nd Edition <http://shop.oreilly.com/product/0636920033073.do> (O'Reilly) Lightbend <http://lightbend.com> @deanwampler <http://twitter.com/deanwampler> http://polyglotprogramming.com On Wed, Jun 29, 2016 at 11:03 AM, Shekar Tippur <ctip...@gmail.com> wrote: > Thanks for the suggestion Lohith. Will try that and provide a feedback. > > - Shekar > > On Tue, Jun 28, 2016 at 11:45 PM, Lohith Samaga M < > lohith.sam...@mphasis.com > > wrote: > > > Hi Shekar, > > Alternatively, you could make each stage of your pipeline to > write > > to a Cassandra (or other DB) and your API will read from it. With > Cassandra > > TTL, the row will be deleted after TTL is passed. No manual cleanup is > > required. > > > > Best regards / Mit freundlichen Grüßen / Sincères salutations > > M. Lohith Samaga > > > > > > > > -----Original Message----- > > From: Shekar Tippur [mailto:ctip...@gmail.com] > > Sent: Wednesday, June 29, 2016 12.10 > > To: users > > Subject: Building API to make Kafka reactive > > > > 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 > > Information transmitted by this e-mail is proprietary to Mphasis, its > > associated companies and/ or its customers and is intended > > for use only by the individual or entity to which it is addressed, and > may > > contain information that is privileged, confidential or > > exempt from disclosure under applicable law. If you are not the intended > > recipient or it appears that this mail has been forwarded > > to you without proper authority, you are notified that any use or > > dissemination of this information in any manner is strictly > > prohibited. In such cases, please notify us immediately at > > mailmas...@mphasis.com and delete this mail from your records. > > >
