Re: Creating a Source using an Akka actor

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

Hi Hector!

I know of users that use camel to produce a stream into Apache Kafka and then use Flink to consume and process the Kafka stream. That pattern work well.

Greetings,
Stephan

On Sun, Nov 8, 2015 at 1:33 PM, rmetzger0 <[hidden email]> wrote:

Hi Hector,

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

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



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Creating-a-Source-using-an-Akka-actor-tp2956p3398.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.