search

akka / alpakka

Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
https://doc.akka.io/libraries/alpakka/current/
Other
1.26k stars 643 forks source link

Nats Streaming connector #260

Open gafiatulin opened 7 years ago

gafiatulin commented 7 years ago

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.

achmadns commented 6 years ago

Hello @gafiatulin , I was thinking the same. I see bright future for NATS as it is CNCF project. Could you please share your work?

gafiatulin commented 6 years ago

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.

achmadns commented 6 years ago

Thanks @gafiatulin, I will look into it and might ask your guidance as I also just started looking at stream processing in AKKA.

nolledge commented 4 years ago

A NATS connector would be very helpful for me. Is there any update on this?

gafiatulin commented 4 years ago

@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 commented 4 years ago

@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.

seglo commented 4 years ago

Maybe @nolledge would be up to the challenge? I agree that this looks like an interesting messaging system to add.

nolledge commented 4 years ago

@seglo I would be happy to help. I will have a closer look this weekend to see what I can do.

gafiatulin commented 4 years ago

@nolledge feel free to contact me if you have any questions.

nolledge commented 4 years ago

@gafiatulin thank you. I already wrote you an email with some questions I have.

MrRexZ commented 4 years ago

@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)

gafiatulin commented 4 years ago

@MrRexZ Hi! I am not working on this in fact completely forgot about it, so definitely go ahead. And thank you for doing this!

nolledge commented 4 years ago

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

MrRexZ commented 4 years ago

@gafiatulin Awesome, I'll get started on it this weekend :) @nolledge Gotcha, thank you!

jadedfire commented 3 years ago

@MrRexZ I was curious if were you able to complete the work on this?