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 4FD9F200BCD for ; Sun, 13 Nov 2016 07:04:34 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 4E41D160B14; Sun, 13 Nov 2016 06:04:34 +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 961C4160B00 for ; Sun, 13 Nov 2016 07:04:33 +0100 (CET) Received: (qmail 66736 invoked by uid 500); 13 Nov 2016 06:04:32 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 66726 invoked by uid 99); 13 Nov 2016 06:04:32 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 13 Nov 2016 06:04:32 +0000 Received: from mail-wm0-f51.google.com (mail-wm0-f51.google.com [74.125.82.51]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 36BE41A0484 for ; Sun, 13 Nov 2016 06:04:32 +0000 (UTC) Received: by mail-wm0-f51.google.com with SMTP id g23so45706697wme.1 for ; Sat, 12 Nov 2016 22:04:32 -0800 (PST) X-Gm-Message-State: ABUngvc01l72pDvKgkZZPzY05cTU8++8QrWOm9VbJxJRFSRNjh7nuGllAOnlJRB7CQ5lczuxauLravJQ5bqXwA== X-Received: by 10.28.98.66 with SMTP id w63mr5561846wmb.142.1479017070841; Sat, 12 Nov 2016 22:04:30 -0800 (PST) MIME-Version: 1.0 Received: by 10.195.17.134 with HTTP; Sat, 12 Nov 2016 22:04:10 -0800 (PST) In-Reply-To: <1770849026.2462983.1478873114119@mail.yahoo.com> References: <1770849026.2462983.1478873114119.ref@mail.yahoo.com> <1770849026.2462983.1478873114119@mail.yahoo.com> From: Robert Metzger Date: Sat, 12 Nov 2016 22:04:10 -0800 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Flink Avro Kafka Reading/Writing To: "user@flink.apache.org" , daviD Content-Type: multipart/alternative; boundary=001a114a511c1fdb8f0541287f63 archived-at: Sun, 13 Nov 2016 06:04:34 -0000 --001a114a511c1fdb8f0541287f63 Content-Type: text/plain; charset=UTF-8 Hi, yes, Flink can read and write Avro schema to Kafka, using a custom serialization / deser schema. On Fri, Nov 11, 2016 at 6:05 AM, daviD wrote: > Hi All, > > Does anyone know if Flink can read and write Avro schema to Kafka? > > Thanks > > daviD > --001a114a511c1fdb8f0541287f63 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable

Hi,

yes, Flink can read and = write Avro schema to Kafka, using a custom serialization / deser schema.

On Fri, Nov 11, 2016 at 6:05 AM, daviD <dunongo@yaho= o.com> wrote:

Hi All,

Does anyone know if Flink can read and write Avro schema to Kafka?

Thanks

daviD

--001a114a511c1fdb8f0541287f63--