alpakka
alpakka copied to clipboard
akka
Nats Streaming connector
Nats Streaming is a data streaming system powered by NATS.
I've implemented some sources and sinks wrapping official java client for usage in private projects. I'd like to contribute it as an alpakka module, if the community is interested.
Hello @gafiatulin , I was thinking the same. I see bright future for NATS as it is CNCF project. Could you please share your work?
Hello @achmadns ,
Sure, everything is available here: https://github.com/gafiatulin/akka-nats-streaming.
Unfortunately at this point I don't have time to make the code pull-request worthy. Currently it is kind of rough and missing tests and documentation.
I encourage you or anyone interested to take this code or parts of it and use it as a base for a full-fledged implementation.
I might be able to work on it a little bit later once I get less busy. In the meantime feel free to ask me any questions.
Thanks @gafiatulin, I will look into it and might ask your guidance as I also just started looking at stream processing in AKKA.
A NATS connector would be very helpful for me. Is there any update on this?
@nolledge
I have not really touched this for last 2 years after changing job.
I can update dependencies/code and prepare PR, but unfortunately probably won't be able to push it over the line on my own at least not right now.
Basically same answer as in https://github.com/akka/alpakka/issues/260#issuecomment-396929538. Docs and tests are the most pressing areas.
@achmadns, did you get a chance to look into this?
@achmadns, did you get a chance to look into this? Sorry, @nolledge, I didn't continue working on and no plan in the future so far.
Maybe @nolledge would be up to the challenge? I agree that this looks like an interesting messaging system to add.
@seglo I would be happy to help. I will have a closer look this weekend to see what I can do.
@gafiatulin thank you. I already wrote you an email with some questions I have.
@nolledge @gafiatulin Hi, can I ask if anyone is still working on this? :) If not, I'd like to take this (as I already had it working with latest dependencies in my private project)
@MrRexZ Hi! I am not working on this in fact completely forgot about it, so definitely go ahead. And thank you for doing this!
Hi @MrRexZ, I did some modifications for corner cases I have found and added some tests. But still the documentation was not complete and some polishing needs to be done. Lately I got distracted...
Maybe this might help you: https://github.com/nolledge/alpakka
@gafiatulin Awesome, I'll get started on it this weekend :) @nolledge Gotcha, thank you!
