flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Status of Kafka011JsonTableSink for 1.4.0 release?
Date Mon, 27 Nov 2017 09:53:50 GMT
Hi George,

Flink 1.4 will not include a KafkaTableSink for Kafka 0.11 but a DataStream
API SinkFunction (KafkaProducer).
As an alternative to usingthe Kafka010TableSink, you can also convert the
result Table into a DataStream and use the KafkaProducer for Kafka 0.11 to
emit the DataStream.

We will hopefully add Kafka 0.11 TableSink with Flink 1.5 which is
scheduled for early next year.

Best, Fabian

2017-11-26 2:31 GMT+01:00 Georgios Kaklamanos <georgios.kaklamanos@gwdg.de>:

> Hello,
>
> I'm new to Flink and I'd like to use it along with Kafka 0.11, to do
> some processing on a stream of JSON data.
>
> I've been looking the docs of the Table API (and the relevant GitHub
> code), and I see that recently there was a Kafka011JsonTableSource
> submitted, which will be available in the Flink 1.4 release.
>
> Would there also be a Kafka011JsonTableSink in the near future (1.4
> release), or I'd have to fall back to Kafka 0.10 for now?
>
> Thank you for your time.
>
> Best Regards,
> George
>
>
>
> --
> ------------------------------------------------------------------
> Georgios Kaklamanos
> Research Assistant, e-Science Group, GWDG
> mailto: georgios.kaklamanos@gwdg.de
> Telefon: 0551 201-26803
> ------------------------------------------------------------------
> GWDG - Gesellschaft für wissenschaftliche
> Datenverarbeitung mbH Göttingen
> Am Faßberg 11, 37077 Göttingen, Germany
>
> WWW: www.gwdg.de    mailto: gwdg@gwdg.de
> Phone: +49 (0) 551 201-1510
> Fax:   +49 (0) 551 201-2150
> ------------------------------------------------------------------
> Geschäftsführer: Prof. Dr. Ramin Yahyapour
> Aufsichtsratsvorsitzender: Prof. Dr. Christian Griesinger
> Sitz der Gesellschaft: Göttingen
> Registergericht: Göttingen
> Handelsregister-Nr. B 598
> ------------------------------------------------------------------
> Zertifiziert nach ISO 9001
> ------------------------------------------------------------------
>
>
>

Mime
View raw message