flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization
Date Fri, 26 Aug 2016 09:25:20 GMT

    [ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438710#comment-15438710

Stephan Ewen commented on FLINK-3874:

I think this needs some improvement. I also commented on the issue:

Do we need tests here that fire up Kafka clusters? Those are very time intensive, they are
tough to harden so that the build is reliable, and what do they really add here?
Assuming the the Kafka connector works, this should test the "add on" by the TableSource.
That can be done with a mock FlinkKafkaConsumer.

I think it would be very good to update this.

> Add a Kafka TableSink with JSON serialization
> ---------------------------------------------
>                 Key: FLINK-3874
>                 URL: https://issues.apache.org/jira/browse/FLINK-3874
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table API & SQL
>            Reporter: Fabian Hueske
>            Assignee: Ivan Mushketyk
>            Priority: Minor
> Add a TableSink that writes JSON serialized data to Kafka.

This message was sent by Atlassian JIRA

View raw message