Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id EBA9B200C52 for ; Mon, 10 Apr 2017 09:51:00 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id EA4E5160B99; Mon, 10 Apr 2017 07:51:00 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 3DA7B160B85 for ; Mon, 10 Apr 2017 09:51:00 +0200 (CEST) Received: (qmail 84595 invoked by uid 500); 10 Apr 2017 07:50:59 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 84585 invoked by uid 99); 10 Apr 2017 07:50:59 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 10 Apr 2017 07:50:59 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id D86F418056F for ; Mon, 10 Apr 2017 07:50:58 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.129 X-Spam-Level: ** X-Spam-Status: No, score=2.129 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id Sm12t_7n4iRJ for ; Mon, 10 Apr 2017 07:50:54 +0000 (UTC) Received: from mail-lf0-f49.google.com (mail-lf0-f49.google.com [209.85.215.49]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 7540E5FC6F for ; Mon, 10 Apr 2017 07:50:53 +0000 (UTC) Received: by mail-lf0-f49.google.com with SMTP id z15so66157823lfd.1 for ; Mon, 10 Apr 2017 00:50:53 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :cc; bh=aBmkfBxBYvn2ogwNo64knAjg/eUCrfwmyz2SAVIQmRY=; b=c9074Dwvp0C6q/LV41MFCLwfQ6Ub6W80kA9wnecZqAH/FPLBuT6O+xHVxHPlgmsjYP xCtPmCYtRFD4Td5V96e/t16g5REy4Hfa5/A7dVWtucMfDZ6lGjWnZ9mJYJL8L8KkrRgD kFzyfTDYc1OubusAOOpcSpuemRYzES6tSEziKMsWUOf/iB0n6fOPKtn/Bsv85IWI7ras xyPkF1Ge12vyI0UEBVQUuFC08u7t/SUB6r4LNHokVi6j/D4Qa5DR4In/M9PrJI3RGrmB mNXoSaNMoTDRRChd2Yx71rJmqehhLxloHDTxVVZSugWnWxdIyagVjKBCLs+PInELCBO6 Mk3w== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to:cc; bh=aBmkfBxBYvn2ogwNo64knAjg/eUCrfwmyz2SAVIQmRY=; b=ATiZ06Tfz+Wb1z/T5ae2uYitpEyj9fMnGJE+EwJElzkAKWVGPxcEYDjJlSDXRsqwKl rGism88OtQNJKpFfP3EcLiEU4yEL3F0QGY4EHbDCYoLeVeDXzzj95J0lCRAvu7UiCYdo N+u8rrUyLkyg5ziELfuUEuX9pGD68P39M8RGINhDrYZAcOQO0qQTcH8270p1WIRsStaD qALyr/dJpWK4l9gIPPP+gpY9LB17PHlqxfdarP26ThdRplqrI5q9r3l4W491uJqPH4H7 F6g87/obsupWusqBEGIrBV2DMQuhpIveIWhuAS+hdfAU3rybsUJoqpXoUh/G1Ws7uNqg gG7Q== X-Gm-Message-State: AFeK/H2sajNhfVxQe5LmBc8A5n4gXj5Eo1DpY+fsrBsQMuDRJljV85efwMXJuSC8WjdEieJsNIrcP7HiExmbIg== X-Received: by 10.25.125.197 with SMTP id y188mr17275830lfc.172.1491810652423; Mon, 10 Apr 2017 00:50:52 -0700 (PDT) MIME-Version: 1.0 Received: by 10.25.92.77 with HTTP; Mon, 10 Apr 2017 00:50:51 -0700 (PDT) In-Reply-To: References: <58E5F20F.30801@apache.org> From: Archit Mittal Date: Mon, 10 Apr 2017 13:20:51 +0530 Message-ID: Subject: Re: Connector for REST End Point To: Chesnay Schepler Cc: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a114b8232028c69054ccb3c1e archived-at: Mon, 10 Apr 2017 07:51:01 -0000 --001a114b8232028c69054ccb3c1e Content-Type: text/plain; charset=UTF-8 Hi Any suggestions regarding this. Thanks Archit On Thu, Apr 6, 2017 at 2:52 PM, Archit Mittal wrote: > Hi Chesnay > > I have a REST Api that listens to events that come through Kafka but i > dont have access to that Kafka . Can I write a connector that consumes > events through the REST end point and not directly through Kafka. > > I have a solution that i can dump the events coming to the api into > another Kafka instance and consume through that but it will add another hop > to the flow. > > Is There a better way to do this by writing a custom connector or > something like that . > > Thanks > Archit > > On Thu, Apr 6, 2017 at 1:15 PM, Chesnay Schepler > wrote: > >> Hello, >> >> Please give us a bit more information, I'm really not sure what you mean. >> :( >> >> Regards, >> Chesnay >> >> >> On 06.04.2017 09:40, Archit Mittal wrote: >> >>> Hi >>> >>> Can we write a custom connector listening to a REST Api end point in >>> Flink >>> >>> Thanks >>> Archit >>> >> >> > --001a114b8232028c69054ccb3c1e Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi

Any suggestions regarding this.

Thanks
Archit

On Thu, Apr 6, 2017 at 2:52 PM, Arch= it Mittal <marchit51@gmail.com> wrote:
Hi Chesnay

I have a REST= Api that listens to events that come through Kafka but i dont have access = to that Kafka . Can I write a connector that consumes events through the RE= ST end point and not directly through Kafka.=C2=A0

I have a solution that i can dump the events coming to the api into anothe= r Kafka instance and consume through that but it will add another hop to th= e flow.=C2=A0

Is There a better way to do this by = writing a custom connector or something like that .=C2=A0

Thanks
Arc= hit

On Thu, Apr 6, 2017 at = 1:15 PM, Chesnay Schepler <chesnay@apache.org> wrote:
Hello,

Please give us a bit more information, I'm really not sure what you mea= n. :(

Regards,
Chesnay


On 06.04.2017 09:40, Archit Mittal wrote:
Hi

Can we write a custom connector listening to a REST Api end point=C2=A0 in = Flink

Thanks
Archit



--001a114b8232028c69054ccb3c1e--