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 1FBBF200BA8 for ; Mon, 24 Oct 2016 11:51:05 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 1E5C1160AEB; Mon, 24 Oct 2016 09:51:05 +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 64CBC160AE1 for ; Mon, 24 Oct 2016 11:51:04 +0200 (CEST) Received: (qmail 1018 invoked by uid 500); 24 Oct 2016 09:50:58 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 999 invoked by uid 99); 24 Oct 2016 09:50:58 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 24 Oct 2016 09:50:58 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 5E39A2C0D55 for ; Mon, 24 Oct 2016 09:50:58 +0000 (UTC) Date: Mon, 24 Oct 2016 09:50:58 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-4837) flink-streaming-akka source connector MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Mon, 24 Oct 2016 09:51:05 -0000 [ https://issues.apache.org/jira/browse/FLINK-4837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15601489#comment-15601489 ] ASF GitHub Bot commented on FLINK-4837: --------------------------------------- Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2644 We recently started collaborating with Apache Bahir (http://bahir.apache.org) to host additions. That makes it easier to add new connectors and to do faster releases of connectors. The Bahir website does not yet reflect that, because it started recently and the first release of Flink connectors is still pending. What do you think about adding this to Bahir as well? @rmetzger can probably help out here. > flink-streaming-akka source connector > ------------------------------------- > > Key: FLINK-4837 > URL: https://issues.apache.org/jira/browse/FLINK-4837 > Project: Flink > Issue Type: New Feature > Components: Streaming Connectors > Reporter: Subhobrata Dey > > Hello, > This issue is created to propose the idea of having a flink-streaming-akka source connector. > The source connector can be used to receive messages from an Akka feeder or publisher actor & these messages can then be processed using flink streaming. > The source connector has the following features. > 1. It can supports several different message formats like iterable data, bytes array & data with timestamp. > 2. It can send back acknowledgements to the feeder actor. > Thanks & regards, > Subhobrata -- This message was sent by Atlassian JIRA (v6.3.4#6332)