You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by rmetzger0 <rm...@apache.org> on 2015/11/08 13:33:02 UTC

Re: Creating a Source using an Akka actor

Hi Hector,

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

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.

Re: Creating a Source using an Akka actor

Posted by Stephan Ewen <se...@apache.org>.
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 <rm...@apache.org> wrote:

> Hi Hector,
>
> I'm sorry that nobody replied to your message so far. I think you are not
> subscribed to the user@flink.apache.org mailing list when you posted this
> question. Therefore, we Flink community didn't receive your message. To
> subscribe, send an email to user-subscribe@flink.apache.org.
>
> 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.
>