Re: Creating a Source using an Akka actor

Posted by rmetzger0 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Creating-a-Source-using-an-Akka-actor-tp2956p3398.html

Hi Hector,

I'm sorry that nobody replied to your message so far. I think you are not subscribed to the [e-mail] mailing list when you posted this question. Therefore, we Flink community didn't receive your message. To subscribe, send an email to [e-mail].

Regarding your question: There is right now no way of receiving Akka messages into a DataStream, so you have to implement an actor system yourself using the "SourceFunction" interface.

I'm not aware of any Apache Camel endpoints, or any plans to implement those. However, contributions are always welcome ;)

Regards,
Robert