Re: Flink SinkFunction for WebSockets

2019-07-23 Thread Oytun Tez
Hi Tim, I think this might be a useful sink for small interactions with outside. Are you planning to open source this? If yes, can you try to make it agnostic so that people can plug in their own WebSocket protocol – Stomp etc? :) We can publish this in the upcoming community website as an extensi

Re: Flink SinkFunction for WebSockets

2019-07-23 Thread Fabian Hueske
Hi Tim, One thing that might be interesting is that Flink might emit results more than once when a job recovers from a failure. It is up to the receiver to deal with that. Depending on the type of results this might be easy (idempotent updates) or impossible. Best, Fabian Am Fr., 19. Juli 2019

Flink SinkFunction for WebSockets

2019-07-18 Thread Timothy Victor
Hi I'm looking to write a sink function for writing to websockets, in particular ones that speak the WAMP protocol ( https://wamp-proto.org/index.html). Before going down that path, I wanted to ask if a) anyone has done something like that already so I dont reinvent stuff b) any caveats or warn