Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
MIME-Version: 1.0
In-Reply-To: <CAAdrtT2rTkP=5UCMW=mriYgdEdg4gMpcQzsr_wUk0Stmnz3_QQ@mail.gmail.com>
References: <CAGApggO-ZiK8nc7UodST8wvL5MjJFk8bjVtNub87kj6oF-Uj6g@mail.gmail.com>
 <CAAdrtT2rTkP=5UCMW=mriYgdEdg4gMpcQzsr_wUk0Stmnz3_QQ@mail.gmail.com>
From: Maximilian Michels <mxm@apache.org>
Date: Thu, 6 Oct 2016 10:57:56 +0200
Message-ID: <CAGco--Z0vEpbdbBCA1fzRcg=giU0bwiDNMmhCgtgDrJFMy7DSA@mail.gmail.com>
Subject: Re: Processing events through web socket
To: "user@flink.apache.org" <user@flink.apache.org>
Content-Type: text/plain; charset=UTF-8
archived-at: Thu, 06 Oct 2016 08:58:26 -0000

Like Fabian said, there is no built-in solution. If you want to use
encryption over a socket, you will have to implement your own socket
source using an encryption library.

On Wed, Oct 5, 2016 at 10:03 AM, Fabian Hueske <fhueske@gmail.com> wrote:
> Hi,
>
> the TextSocketSink is rather meant for demo purposes than to be used in an
> actual applications.
> I am not aware of any other built-in source that would provide what you are
> looking for.
> You can implement a custom SourceFunction that does what you need.
>
> Best, Fabian
>
> 2016-10-05 9:48 GMT+02:00 Abdul Salam Shaikh <abd.salam.shaikh@gmail.com>:
>>
>> I am trying to read data over a websocket from a source(For example
>> wss://brisbane.unipulse.com.au:443/OutboundInterfaces/outbound/statements).
>> But at the moment the implementation of env.socketTextStream only supports
>> plain TCP and has no support for TLS or higher level protocols. Is there any
>> other wrapper/third party API implementation which I can use on top of flink
>> to act as a streaming service before transmitting it to flink ?
>>
>> --
>> Thank
>> s.
>>
>