[
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
(v6.3.4#6332)
