[akka-user] Slow reactive-kafka consumer when running multiple streams

2017-12-27 Thread Harshit Patel
We have an application that uses reactive-kafka to consume messages from a kafka topic, do some validations and transformations on the messages, and then persist to two different datastores. We are using two different reactive kafka consumer streams for each of the datastores, using different c

Re: [akka-user] Distributed Data for production use

2016-02-11 Thread Harshit Patel
dom to change API based on feedback before > committing to binary backwards compatibility. > > The label will be removed in Akka 2.5, and we don't have an ETA. > > /Patrik > ons 10 feb. 2016 kl. 22:41 skrev Harshit Patel >: > >> I was planning on using distribut

[akka-user] Distributed Data for production use

2016-02-10 Thread Harshit Patel
I was planning on using distributed-data for sharing data across the nodes in the cluster. I know the API is marked as experimental, and am not worried about possible API changes in the future. However, I just wanted to know if it is stable enough from a functionality perspective to use in a pr