Creating a Source using an Akka actor

[hveiga]

Hi,

Is there any way to create a source using an Akka actor? It would be really powerful to be able to use any akka actor as source. The only way I know now is to implement the run() method while extending the interface SourceFunction.

On the same page, it would be good to be able to use any Apache Camel endpoint as source or sink.

Is there any work planned to make this happen?

Thanks,

Héctor.

[rmetzger0]

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

[Stephan Ewen]

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.